Bir konuya/bölüme mesaj yazan bir yapımcım var. Siparişi korumak için, tek bir bölümle gitmek istiyorum ve 12 tüketicinin bu tek bölümdeki tüm mesajları okumasını istiyorum (hiçbir tüketici grubu, tüm mesajlar tüm tüketicilere gitmeli). Bu ulaşılabilir mi? Her bir bölüm için sadece bir tüketicinin okuyabileceği bazı forumları okudum.Kafka bir bölüm için çok sayıda tüketici
cevap
Sen soruyorsun tam olarak ne elde etmek SimpleConsumer
kullanabilir - hayır tüketici grupları, tüm tüketiciler tek bir bölüm okuyabilirsiniz. Ancak bu yaklaşım, ofset depolama ve komisyoncu arızasıyla başa çıkmak zorunda olduğunuz anlamına gelir.
Başka bir seçenek (sadece her tüketiciye rastgele UUID atayabilirsiniz) farklı tüketici gruplarıyla üst düzey tüketiciye kullanmaktır. Bu şekilde, tüm tüketicilerle bir konu/bölüm tüketebilecek ve ofsetleri işleyebilecek ve komisyoncu kesintisini kaldırabileceksiniz.
kuralı "sadece konu/bölüm tüketebilir tek tüketici" sadece tüketici grupları için geçerlidir, mesela IN GROUP yalnızca bir kişi/bölüm aynı anda tüketebilir. Eğer aynı bölüme birden tüketicileri varsa
, bu sıralamayı sürdürmenin başlangıç şartı yener. Bununla birlikte, depolama siparişi vermiş olsaydınız, ancak tüketim sipariş edilmeyecekti. Bununla gerçekten iyi olduğundan emin ol. Evet ise, her bir tüketiciye farklı bir tüketici grubu olarak davranabilirsiniz.
- 1. Kafka Tüketici, aralık dışında
- 2. Apache Kafka Çoklu Tüketici Örnekleri
- 3. Bir ileti wth java tabanlı Kafka Tüketici
- 4. Kafka alway bir tüketici konu mesajını bir grupta tüketir
- 5. kafka tüketici Ben Kafka sunucusundan mesajları (konular) tüketmeye KafkaConsumer kullanıyorum
- 6. Sıfırlama tüketici 0,10 olarak kafka 0.10
- 7. Yay Bütünleşmesi Kafka Tüketici Dinleyicisi iletileri almıyor
- 8. Apache Kafka konsolu Üretici-Tüketici örneği
- 9. Bir kafka konusundaki LATEST ofsetini nasıl alabilirim?
- 10. kafka bölümü yeniden dengeleme (atama) çok fazla zaman alıyor
- 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. Çok sayıda okuyucu/üretici için "Control.Concurrent.Chan" güvenli kanallar var mı?
- 13. java'daki çok sayıda istemci iletişimi
- 14. Çok işlemcili - üretici/tüketici dizaynı
- 15. Kafka 0.9.0'da çok parçalı tüketici nasıl kullanılır? tanımlamaktadır aşağıdaki yaklaşık
- 16. java eşzamanlı: çok üretici bir tüketici
- 17. çok sayıda tinymce textareas
- 18. JBoss HornetQ: Tüketici-pencere boyutu yavaş tüketici için ayarlayın
- 19. Çok sayıda yapıcı argümanı
- 20. ValueError: Çok sayıda değerler
- 21. kafka kümesindeki bölüm ve çoğaltma arasındaki fark nedir?
- 22. Değişiklikler için çok sayıda dosyayı nasıl seçmeliyim?
- 23. SQLAlchemy için çok sayıda ilişkiye veri ekleme
- 24. Kafka üye kimliği mağaza?
- 25. Kafka için SSL'yi Doğrulama Nasıl Çalışır
- 26. Kafka Java'da bir konu için en son oluşturulan bölüm kimliği nasıl bilinir
- 27. Neden numberOfRowsInSection, yalnızca bir bölüm için birden çok kez çağrılıyor?
- 28. Kafka kullanarak kafka sunucusu ile iletişim kurulamıyor Üretici API
- 29. -pek-çok ve çok sayıda çoğa kavşaklar
- 30. kafka acls nasıl kullanılır?
Her tüketici için benzersiz tüketici groupid'i kullanırsam, her müşterinin tüm mesajlarını tek bölümden okuyacağım. yani kod gibi bir şey .. props.put ("group.id", KafkaProperties.groupId); – skumar
Evet, eğer tek bir bölümlü konunuzda 1000 mesaj varsa, farklı tüketici gruplarına sahip tüm tüketiciler her biri 1000 mesaj okuyacaktır. – serejja
Yaklaşım1 (ofset ve broker failer) ve yaklaşım 2 için (her bir tüketiciye randevu atama) birkaç örnek verebilir misiniz? – skumar