This repository has been archived by the owner on Mar 30, 2023. It is now read-only.
Support custom Producer RecordMessageConverter #290
Comments
garyrussell
added a commit
to garyrussell/spring-integration-kafka
that referenced
this issue
Oct 30, 2019
garyrussell
added a commit
to garyrussell/spring-integration
that referenced
this issue
Jun 24, 2020
artembilan
pushed a commit
to spring-projects/spring-integration
that referenced
this issue
Jun 25, 2020
Sign up for free
to subscribe to this conversation on GitHub.
Already have an account?
Sign in.
It appears that it isn't possible to specify a custom
RecordMessageConverterfor a producer. While you are able to set the message converter on theKafkaProducerMessageHandler's template, internally the handler constructs aProducerRecordand then callsKafkaTemplate.send(ProducerRecord<K, V> record)which bypasses the template's message converter.See: https://github.com/spring-projects/spring-integration-kafka/blob/master/src/main/java/org/springframework/integration/kafka/outbound/KafkaProducerMessageHandler.java#L411
Original spring-cloud-stream issue: spring-cloud/spring-cloud-stream-binder-kafka#790
The text was updated successfully, but these errors were encountered: