Я пытаюсь обновить наш KafkaBroker с 0.10.2 до 1.1.3 , включая формат журнала сообщений.
В настоящее время наш java Kafka-Consumer-Client 2.0.1 можетпотреблять от KafkaBroker 0.10.2 после обновления до KafkaBroker 1.1.3, a consumer is not consuming message at all.Также onPartitonAssigned zero partition is getting assigned.С точки зрения конфигурации потребителя, я использую все значения по умолчанию, кроме enable.auto.commit: false, auto.offset.reset: latest/earliest(tried both) and bootstrapServers according to the broker I am consuming from
Я пытался использовать консольный потребитель ./kafka-console-consumer.sh Kafka-Consumer-Client 2.0.1, и он работает нормально и может принимать сообщение.
Кроме того,Я не получаю никаких ошибок или исключений при потреблении.Я получил следующее сообщение журнала от координатора "msg": "[Consumer clientId=..., groupId=foo.bar.test] The following subscribed topics are not assigned to any members: [foo_bar_test]"
Любая помощь будет оценена