создать собственный кафкаппроизводитель

Question

Я изучаю Кафку, и я пытался использовать python для написания собственного производителя.

Я пытался играть с простым циклом, однако я получил ошибку утверждения:

from kafka import KafkaProducer
from kafka.errors import KafkaError

producer = KafkaProducer(bootstrap_servers=['127.0.0.1:7092'])
for x in range (10):
    topic = "kafkatopic"
    producer.send(topic=topic,value="text")
    x=x+1

Неконечно, почему.

Answer 1

вы можете проверить этот код, и я использую клиент Kafka Python пакет:

producer.py:

from kafka import KafkaProducer

producer = KafkaProducer(
    bootstrap_servers=['XX.XXX.XXX.XXX:9092'],
)
for x in range (10):
    producer.send('kafkatopic', b'this is a test')
    producer.flush()

print('finish')

consumer.py

from kafka import KafkaConsumer

consumer = KafkaConsumer('kafkatopic',
                     bootstrap_servers=['XX.XXX.XXX.XXX:9092'],
                     auto_offset_reset= 'smallest')
for message in consumer:
    print ("%s:%d:%d: key=%s value=%s" % (message.topic, message.partition,message.offset, message.key,message.value))