I need to get token that strimzi-oauth-lib is getting from my oracle access manager. This library provides a JaasClientOauthLoginCallbackHandler and kafka take care of make an callback and gets token by its own. I was wondering if is possible to recover this token and reuse it on my microservice.

@Bean public RecordMessageConverter converter() { // return new JsonMessageConverter(); JsonMessageConverter jsonMessageConverter = new JsonMessageConverter(); jsonMessageConverter.setHeaderMapper(new CustomKafkaHeaderMapper()); return jsonMessageConverter; } @Bean public BatchMessagingMessageConverter batchConverter() { // return new BatchMessagingMessageConverter(converter()); BatchMessagingMessageConverter batchMessagingMessageConverter = new BatchMessagingMessageConverter(converter()); batchMessagingMessageConverter.setHeaderMapper(new CustomKafkaHeaderMapper()); return batchMessagingMessageConverter; } public class CustomKafkaHeaderMapper extends DefaultKafkaHeaderMapper { @Override public void toHeaders(Headers source, Map<String, Object> target) { super.toHeaders(source, target); […]

@Bean public RecordMessageConverter converter() { // return new JsonMessageConverter(); JsonMessageConverter jsonMessageConverter = new JsonMessageConverter(); jsonMessageConverter.setHeaderMapper(new CustomKafkaHeaderMapper()); return jsonMessageConverter; } @Bean public BatchMessagingMessageConverter batchConverter() { // return new BatchMessagingMessageConverter(converter()); BatchMessagingMessageConverter batchMessagingMessageConverter = new BatchMessagingMessageConverter(converter()); batchMessagingMessageConverter.setHeaderMapper(new CustomKafkaHeaderMapper()); return batchMessagingMessageConverter; } public class CustomKafkaHeaderMapper extends DefaultKafkaHeaderMapper { @Override public void toHeaders(Headers source, Map<String, Object> target) { super.toHeaders(source, target); […]

I want to consume all the kafka messages from 0 offset in startup of my spring boot application whenever my service restart. Below is my kafka configuration but it is not working.

I have a Spring Boot application which acts as a producer and consumer for a Kafka cluster (Spring Kafka v3.0.17, Kafka client v3.4.1). App and cluster run both on Kubernetes. Additionally, the app uses a Kafka admin client for some administrative tasks.

In our Application we are trying to use Spring-Kafka for REquest Reply Semantics

This is the acknowledgement class:

I’m using Spring Kafka for producing to a Kafka topic and consuming from it.
Everything works fine and as expected.

Is there a way to specify the dlt used when retrying with spring-kafka @RetryableTopic.