79684931

Date: 2025-06-30 14:48:04
Score: 0.5
Natty:
Report link

Add below bean and it will fix the above mentioned issue on cloud kafka.

@Bean
    public ListenerContainerCustomizer<AbstractMessageListenerContainer> containerCustomizer() {
        return (container, dest, group) -> container.getContainerProperties()
                .setAuthExceptionRetryInterval(Duration.ofSeconds(30));
    }

Read here.

Reasons:
  • Has code block (-0.5):
  • Self-answer (0.5):
  • Low reputation (0.5):
Posted by: LetsCode