2016-03-21 31 views
1

Kafka kümesinde 8 bölümlü bir konu var. Konu 8 ve offsetManager KafkaTopicOffsetManager olduğunu KafkaMessageDrivenChannelAdapter ile konu tüketmek için uygulama uygulanmaktadır. Bir uygulama örneğini başlattığımda her şey doğru. Ama iki uygulama örneğine başladığımda, meesenin iki kez tüketildiğini görüyorum. Nedenini ve nasıl çözeceğini biliyor musunuz? HighLevelConsumer'a ihtiyacım var mı?İleti iki kez tükeniyor

cevap

1

Bölmeleri, bu bağdaştırıcıyla örneklere dağıtmanız gerekir.

Tüketici gruplarını destekleyen kafka 0.9 java istemcilerine geçiş yapmak için çalışıyoruz.

The first milestone for the core project is available.

Bu yeni istemciyi kullanan bir ilkbahar-tümleştirme-kafka 2.0 kilometre taşı bırakmaya çalışmalıyız.

+0

Yanıtınız için teşekkürler, spring-integration-kafka 2.0 sürümü için sabırsızlanıyoruz. –