search

micronaut-projects / micronaut-kafka

Integration between Micronaut and Apache Kafka
Apache License 2.0
84 stars 101 forks source link

KafkaListener breaks on unauthorized topic #9

Open AjiTae opened 5 years ago

AjiTae commented 5 years ago

@KafkaListener does not listen to all (or some - each run differs) @Topic's , if at least one@Topic is not authorized by the broker.

Example kafka docker and service: https://github.com/AjiTae/micronaut-unauthorized-listener-issue

graemerocher commented 5 years ago

In your example the listener fails with:

08:22:39.276 [pool-1-thread-4] ERROR i.m.c.k.e.KafkaListenerExceptionHandler - Kafka consumer [kafka.testing.service.kafka.KafkaTopicListener@adcfe50] produced error: No entry found for connection 0
java.lang.IllegalStateException: No entry found for connection 0
        at org.apache.kafka.clients.ClusterConnectionStates.nodeState(ClusterConnectionStates.java:330)
        at org.apache.kafka.clients.ClusterConnectionStates.disconnected(ClusterConnectionStates.java:134)
        at org.apache.kafka.clients.NetworkClient.initiateConnect(NetworkClient.java:921)
        at org.apache.kafka.clients.NetworkClient.ready(NetworkClient.java:287)

Is that the behaviour you are seeing too?