Я создал приложение потока kafka, но после его запуска kafka продолжает балансировать с этим исключением до состояния ошибки:
Exception in thread "t-StreamThread-5" java.lang.IllegalStateException: Consumer was assigned partitions [xxx] which didn't correspond to subscription request [] at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.handleAssignmentMismatch(ConsumerCoordinator.java:218)
Я использую: springboot 2.2.1, kafka-streams: 2.3.0, kafka: 2.3.0
Есть идеи?