How can I use Apache Kafka in Python?

How can I use Apache Kafka in Python?

You can use the kafka-python library to interact with Apache Kafka in Python. Would you like a quick setup guide?

Yes, please provide a setup guide.

First, install the library using pip: pip install kafka-python. Then, you can create a producer and a consumer.

Can you show me a simple example of a producer?

Sure! Here's a basic example:

from kafka import KafkaProducer
producer = KafkaProducer(bootstrap_servers='localhost:9092')
producer.send('my_topic', b'Hello, Kafka!')
producer.close()

What about a consumer example?

Here's a simple consumer example:

from kafka import KafkaConsumer
consumer = KafkaConsumer('my_topic', bootstrap_servers='localhost:9092')
for message in consumer:
    print(message.value)