I’ve a scheduled Spring method and got issue with my kafka configuration org.apache.kafka.common.errors.TopicAuthorizationException or “org.springframework.kafka.KafkaListenerEndpointContainer.
Now every time my service is in loop with above exceptions and prints messages like:
The request was rejected by firewall checks.
...
Connection to node 0 terminated during authentication. This may happen due to any of the following reasons: (1) Authentication failed due to invalid credentials with brokers older than 1.0.0, (2) Firewall blocking Kafka TLS traffic (eg it may only allow HTTPS traffic), (3) Transient network issue.
Due to that there’s no any log from my scheduled spring method.
I’m using Java 21 with virtual threads enabled.
I tried to disable them, but issue with loop still exist and scheduled spring method is not executed. It’s really important to execute this scheduled method.