Hi,

I am trying to implement Kafka producers using Apache Camel.

I want to know Kafka error codes (defined in Kafka protocol guide: (
https://kafka.apache.org/11/protocol.html#protocol_error_codes )

I also tried by writing Kafka producer in spring boot app,
1. used Producer Interceptor
2. Used Callbacks
3. Used Futures<> callback

But none of them worked for me.

Eg., If I send incorrect topic name, I only get timeout exception after 60s.

Q: How do I get to know the Error Code and Error Name for timeout or any
other error as given in link above?

Thanks in advance.

Reply via email to