spring-integration
spring-integration copied to clipboard
Support ErrorHandlingDeserializer in KafkaMessageSource
Expected Behavior
Similar logic to the listener container - send deserialization exceptions to the error channel.
Current Behavior
User has to manually move past the bad record by setting the offset.
Context