kafka-consumer-api

10ısı

1cevap

Kafka auto commit ve auto.commit.interval.ms ile ilgili açıklama gerekir.

https://www.safaribooksonline.com/library/view/kafka-the-definitive/9781491936153/ch04.html belgesi, belgesine sahiptir "Otomatik yanıtlama etkinken, yoklama çağrısının her zaman önceki yoklama tarafı

5ısı

1cevap

Kafka Tüketici, aralık dışında

için yapılandırılmış sıfırlama ilkesi olmadan aralık dışı ofsetler Kafka tüketicisine başlarken istisna alıyorum. org.apache.kafka.clients.consumer.OffsetOutOfRangeException: bölümleri için yapılandır

5ısı

2cevap

KafkaConsumer 0.10 Java API hata iletisi: Bölüm için geçerli atama yok

KafkaConsumer 0.10 Java API'yi kullanıyorum. Belirli bir bölümden ve belirli bir ofsetten tüketmek istiyorum. Yukarı baktım ve bir arama yöntemi olduğunu ancak bunun bir istisna attığını keşfettim. Be

2ısı

1cevap

kafka bölümü yeniden dengeleme (atama) çok fazla zaman alıyor

3 sunucu ile kafka küme kullanıyoruz, hepsi de zookeeper kullanıyor. 6 bölümden oluşan 7 konuya sahibiz. Her konu için 3 java tüketicimiz var. Tüketiciye başladığımda, tüketicilere bölüm atamak nerede

8ısı

2cevap

Kafka, java.nio.channels.ClosedChannelException'ı atar

Kafka konsol aracıyla ec2'de barındırılan kafka sunucusundan ileti almaya çalıştığımda (V 0.9.0.1, bunun eski tüketici API'lerini kullandığını düşünüyorum) Aşağıdaki istisnaları alıyorum . Bunu nasıl

2ısı

1cevap

Kafka Spark'de tüketici grubu nasıl belirtilir? Doğrudan akış kullanarak akış yapma

Doğrudan akış API'si kullanarak kafka kıvılcımı akışı için tüketici grubu kimliği nasıl belirtilir. Yapılandırmayı belirttiğim bir şey eksik olup olmadığından emin olmamama rağmen . kullanarak 1.11 ka

8ısı

3cevap

Bir kafka konusundaki LATEST ofsetini nasıl alabilirim?

Java kullanarak kafka tüketici yazıyorum. Mesajın gerçek zamanını tutmak istiyorum, bu yüzden tüketmek için bekleyen çok fazla mesaj varsa, 1000 veya daha fazlası gibi, tükenmemiş mesajları terk etmel

1ısı

1cevap

Bluemix ve Node-Red'deki Kafka düğümlerini kullanma

Bir Kafka giriş düğümü (node-red-contrib-kafka-node) kullanarak bir Bluemix düğümü-kırmızı uygulamasında iletileri kullanmaya çalışıyorum. Uygulamamıza bağlı bir ileti merkezi hizmetim var ve bir hazı

4ısı

3cevap

kafka-python - Bir bölümü nasıl işlerim?

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

7ısı

1cevap

Avro kod çözme, java.io.EOFException

Kafka 0.0.8V ile Apache avro şemasını kullanır. Ben üretici/tüketici uçlarında aynı şemayı kullanın. Şemada NO HERHANGİ Değişiklikler var. Ama ben mesajları tüketmeye çalıştığımda tüketiciye bir istis