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. Ama şimdi her zaman aynı tüketici sunucusu A gibi görünüyor mesajlar tüketir, başka biri mesajlar tüketmez.Eğer tüketici sunucusu A durdurursam, başka bir iyi çalışır. Ne mesaj beklediğimi umarım rastgele.Kafka alway bir tüketici konu mesajını bir grupta tüketir
0
A
cevap
2
İki tüketici örneğini paralel olarak kullanabilmek için konuyla ilgili en az iki bölüm gerekir. Bir tüketici, aynı konunun bulunduğu bir konunun ve diğer tüketicilerin bir veya daha fazla bölümüne bağlanacaktır. Tüketiciler zaten onlara bağlı olan bölümleri talep etmeyecektir. Bir tüketici başarısız olursa/çökerse, bölüm serbest bırakılır ve daha sonra başka bir tüketici örneği tarafından alınır.
İlgili konular
- 1. Kafka Tüketici, aralık dışında
- 2. Bir ileti wth java tabanlı Kafka Tüketici
- 3. Kafka bir bölüm için çok sayıda tüketici
- 4. kafka tüketici Ben Kafka sunucusundan mesajları (konular) tüketmeye KafkaConsumer kullanıyorum
- 5. Apache Kafka Çoklu Tüketici Örnekleri
- 6. Yay Bütünleşmesi Kafka Tüketici Dinleyicisi iletileri almıyor
- 7. Apache Kafka konsolu Üretici-Tüketici örneği
- 8. Sıfırlama tüketici 0,10 olarak kafka 0.10
- 9. Kafka 0.9 - java api ile bir konu nasıl oluşturulur
- 10. Bir kafka konusundaki LATEST ofsetini nasıl alabilirim?
- 11. Kafka 0.8, java kodu kullanarak bölüm ve çoğaltma ile konu oluşturmak mümkün mü? Kafka yılında
- 12. Kafka üye kimliği mağaza?
- 13. Go: Bir üretici, birçok tüketici
- 14. Pylint mesajını bir dosyaya kaydetme
- 15. Kafka kullanarak kafka sunucusu ile iletişim kurulamıyor Üretici API
- 16. Bir konu değişimi
- 17. Kafka Java'da bir konu için en son oluşturulan bölüm kimliği nasıl bilinir
- 18. kafka acls nasıl kullanılır?
- 19. Tüm açısal onay kutularını bir grupta değiştir
- 20. Django RabbitMQ Tüketici
- 21. Kafka 0.9.0'da çok parçalı tüketici nasıl kullanılır? tanımlamaktadır aşağıdaki yaklaşık
- 22. C# Sadece Bir Konu Yürütüyor
- 23. Grupta grup resmi JavaFX
- 24. java eşzamanlı: çok üretici bir tüketici
- 25. Rakip bir tüketici çözümü nasıl uygulanır?
- 26. Artış Satır Numarası Grupta
- 27. MATLAB'de bir hata mesajını nasıl görüntüleyebilirim?
- 28. Kafka, java.nio.channels.ClosedChannelException'ı atar
- 29. kafka-python - Bir bölümü nasıl işlerim?
- 30. Tüketici grubunu java mesajına nasıl ekleyebilirim?
Tüketici sunucu önceliğini hangi faktörler etkiler? ağ ya da başka bir şey? – fcbflying