spring-kafka

spring-kafka copied to clipboard

Spring Managed Consumer Interceptors

2

Following https://github.com/spring-projects/spring-kafka/issues/2049, Spring Kafka may also support Spring managed interceptors for standard consumers and streams. In pure Kafka, interceptors are specified through a configuration entry. This entry contains the list...

frosiere

consumer group specific offset seeking for AbstractConsumerSeekAware

2

**Expected Behavior** We want to be able to seek offset for specific consumer group by using AbstractConsumerSeekAware. **Current Behavior** regarding to below implementation it is clear that we can seek...

akemalsaglam

Differentiate back-off exceptions from 'real' application errors in Listener Micrometer timer metrics for retry topics

6

**Expected Behavior** As per the [docs on 'Monitoring Listener Performance'](https://docs.spring.io/spring-kafka/docs/latest-ga/reference/html/#monitoring-listener-performance), there are `Micrometer` timers called `spring.kafka.listener` which are tagged with a `result` (`success` or `failure`) and `exception`. I would expect...

theopigott

JsonSerializer implementation prevents extension

3

Implementation of `org.springframework.kafka.support.serializer.JsonSerializer` prevents previously supported extensibility. See the example below: ### Custom JsonSerializer ```java public class ExtendedKafkaJsonSerializer extends JsonSerializer { public static final String USE_DATE_FORMAT = "use.date.format"; public ExtendedKafkaJsonSerializer()...

arabczuk-equinix

Switch from batch to record-by-record processing in case an exception occured.

15

**Current Behavior** When processing serveral records at the same time, it is sometimes impossible to say which record caused an exception and therefore you cannot rise a BatchListenerFailedException. In consequence...

rloeffel

ErrorHandlingDeserializer: should failedDeserializationFunction be mandatory?

1

I took over maintenance of an application that uses Spring Kafka. My former colleague configured the application to make use of `ErrorHandlingDeserializer`, but he didn't configure a `failedDeserializationFunction` and didn't...

bencody

FeatureRequest for @RetryableTopics mechanism: Clean up retry-topics with tombstones after message recovery

18

Hello there 👋 If I got this right, the `@RetryableTopic` mechanism is built in such a way, that messages are written into retry-topics and are processed again after a predefined...

fabiobauer

Add MediaMessage annotation support.

2

Supports the ability to define the content type of Message from the client side for resolving. Usage example: ``` @Configuration public class MediaMessageConfig implements KafkaListenerConfigurer { public CompositeMessageConverter createMessageConverter() {...

scruel

MessagingMessageListenerAdapter.determineInferredType not working when a custom annotation is present Kafka listener method argument

2

I have a kafka listener defined using @KafkaListener annotation with one input argument of type A. If I add a customer annotation @Annotation1 (for example for logging purposes) to this...

namelessone667

Delete one message from Kafka server as it can't deserialized , but not restart Consumer server ,then it continue poll this message caused high CP

4

### **Problem*:* Delete one message from Kafka server as it can't deserialized , but not restart Consumer server ,then it continue poll this message caused high CPU Spring-Kafka version: 2.5.14.Release...

xzhan