pyrkafka 0.1.0

Python bindings for rdfkafka Rust library

rdfkafka

Description

rdfkafka is a Rust library for working with Kafka in Python. It provides a high-level interface for producing and consuming RDF data using the Kafka messaging system.

Features

• Easy integration with Kafka for RDF data processing.
• High-level API for producing and consuming RDF messages.
• Support for various serialization formats (e.g., JSON, Avro, Protobuf).
• Efficient and scalable processing of RDF data.

Installation

You can install rdfkafka using pip:

pip install rdfkafka

Producer Example

from rdfkafka import KafkaProducer


producer = KafkaProducer(bootstrap_servers='localhost:9092')

topic = 'my_topic'
message = 'Hello, Kafka!'
producer.send(topic, message.encode())

Note: producer gets closed when dropped

Consumer Example

from rdfkafka import KafkaConsumer

consumer = KafkaConsumer(bootstrap_servers='localhost:9092')
topic = 'my_topic'


consumer.subscribe(topic)

for message in consumer:
    print(message.value.decode())