Im ofset ama olsun onaylama işlemi hatası ayarlayarak bir konuya veri tüketmeye çalışıyor - from kafka import KafkaConsumer
consumer = KafkaConsumer('foobar1',
bootstrap_servers=['localhos
kafka-python-1.0.2 Kullanımı. 10 bölümlü bir konuğum varsa, çeşitli bölümler ve iletiler arasında döngü yaparken belirli bir bölümün işlenmesiyle ilgili olarak nasıl giderim. Bn sadece docs, bu her ye
Kafka'ya, aşağıda gösterildiği gibi joker karakterli bir desen kullanarak abone oluyorum. Joker, dinamik bir müşteri kimliğini temsil eder. consumer.subscribe(pattern='customer.*.validations')
Bu iy