Ошибка подписки на Kafka Stream - неверная версия

Question

При попытке подключиться к теме из микросервиса Java Jetty, я получаю эту ошибку внутреннего несоответствия версий Kafka:

stream-thread [App-94d44dcd-f1d4-49a6-9dd3-8d4eee06f82a-StreamThread-1] Encountered the following error during processing:
java.lang.IllegalArgumentException: version must be between 1 and 3; was: 4
                at org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfo.<init>(SubscriptionInfo.java:67)
                at org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor.subscription(StreamsPartitionAssignor.java:312)
                at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.metadata(ConsumerCoordinator.java:176)
                at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.sendJoinGroupRequest(AbstractCoordinator.java:515)
                at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.initiateJoinGroup(AbstractCoordinator.java:466)
                at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.joinGroupIfNeeded(AbstractCoordinator.java:412)
                at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureActiveGroup(AbstractCoordinator.java:352)
                at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureActiveGroup(AbstractCoordinator.java:337)
                at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.poll(ConsumerCoordinator.java:333)
                at org.apache.kafka.clients.consumer.KafkaConsumer.updateAssignmentMetadataIfNeeded(KafkaConsumer.java:1218)
                at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1175)
                at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1154)
                at org.apache.kafka.streams.processor.internals.StreamThread.pollRequests(StreamThread.java:861)
                at org.apache.kafka.streams.processor.internals.StreamThread.runOnce(StreamThread.java:814)
                at org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:767)
                at org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:736)

Есть идеи, что может вызвать такое исключение?

Answer 1

Я сам сталкивался с этой ошибкой, и, скорее всего, потому, что вы использовали неуникальный APPLICATION_ID_CONFIG и / или CLIENT_ID_CONFIG

// Give the Streams application a unique name.  The name must be unique in the Kafka cluster
// against which the application is run.
streamsConfiguration.put(StreamsConfig.APPLICATION_ID_CONFIG, "my-app");
streamsConfiguration.put(StreamsConfig.CLIENT_ID_CONFIG, "my-client");