kafka-consumer-api

2ısı

2cevap

kafka tüketici Ben Kafka sunucusundan mesajları (konular) tüketmeye KafkaConsumer kullanıyorum

eklendi .. O Tüketici kodu başlamadan önce oluşturulan konular için çalışıyor ... Ama sorun, dinamik olarak oluşturulan (tüketici kodu başladıktan sonra demek istiyorum demek), ancak dinamik bir konu

java apache-kafka kafka-consumer-api 2016-03-22

---

0ısı

1cevap

Bir ileti wth java tabanlı Kafka Tüketici

okunamadı Bir java Kafka tüketici uygulamaya çalışın. Kafka sunucu sürümünü 0.9 kullanıyorum. Test amaçlı olduğu için tek yapmam gereken tek bir mesaj okumak. iade kayıtlar nesne public static Consume

java kafka-consumer-api 2016-03-22

---

1ısı

1cevap

kafka.consumer.ConsumerTimeoutException nasıl üstesinden gelebilirim?

Tüketici yazmak için kafka 2.11 sürümünü kullanıyorum. Sürekli zaman aşımı istisnası alıyorum. Doğru API'ları kullandığımdan emin değilim. Herkes bana yardımcı olabilir mi? Yürüten import kafka.consum

apache-kafka kafka-consumer-api kafka-producer-api 2016-03-24

---

0ısı

1cevap

Kafka - Fail Bağlanıyor Uzak Broker - HayırBrokersKullanılabilir

3 düğümlü bir küme (google bulut) oluşturdum. Zookeeper tüm düğümlerde koşuyor ve köle düğümlerinden birinde Kafka'yı başlattım. Kümedeki herhangi bir makineden iletişim kurabilir (yayınlayabilir/tüke

apache-kafka kafka-consumer-api 2016-03-26

---

0ısı

1cevap

org.apache.kafka.common.errors.ApiException: Oturum zaman aşımı kabul edilebilir bir aralıkta değil

Tüketicimde 0,9.0,1 kafka ile istisnanın üstesinden gelirim. Bu konuya göre [1] göremiyorum " group.max.session.timeout.ms "server.properties dosyasındaki özellik. org.apache.kafka.common.errors.ApiEx

apache-kafka kafka-consumer-api kafka-producer-api 2016-03-30

---

0ısı

1cevap

Kafka üye kimliği mağaza?

Tüketici Üye Kimliğinin zookeeper veya Kafka'da saklandığını bilen var mı? Onu nasıl silebilirim ya da Grup İsteklerini kaldırmayı kaldırabilirim.

apache-kafka kafka-consumer-api 2016-03-30

---

5ısı

1cevap

kafka: SimpleConsumer için 'soTimeout', 'bufferSize' ve 'minBytes' ne demek?

Kafka 0.8.2.1 SimpleConsumer kullanıyorum. Birisi SimpleConsumer ve FetchRequestBuilder için birkaç config parametresinin anlamını açıklayabilir mi? KAfka'nın kaynak kodunu okumadan kısa bir süre sonr

apache-kafka kafka-consumer-api 2015-06-09

---

0ısı

2cevap

AssertionError: Atanmayan'ı bölüm

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

apache-kafka kafka-consumer-api kafka-python 2016-04-03

---

0ısı

1cevap

Kafka alway bir tüketici konu mesajını bir grupta tüketir

Aynı grup kimliğiyle iki tüketici sunucum var aynı konuya abone oldum. Bir kafka sunucusu sadece bir bölüm ile çalışıyor. Bildiğim kadarıyla, bu iki tüketici sunucusunda mesaj rastgele tüketilmelidir.

apache-kafka kafka-consumer-api kafka-producer-api 2016-04-05

---

5ısı

1cevap

Kafka'da mesajların boyutunu nasıl ayarlayabilirim?

Şu anda Kafka 0.9.0.1 kullanıyorum. Bulduğum bazı kaynaklara göre, mesajların boyutlarını belirlemenin yolu server.properties'da aşağıdaki anahtar değerleri değiştirmektir. message.max.bytes replica.f

java apache-kafka kafka-consumer-api kafka-producer-api 2016-02-29

---