Allow setting a message key for the Kafka binder

[sabbyanandan]

From @Jacuo on July 28, 2016 14:55

Sending message to kafka topic, when cleanup.policy=compact causes error. It looks that problem is with key= null. I tried to set key using

MessageBuilder.withPayload(message)
                            .setHeader(KafkaHeaders.MESSAGE_KEY, key)

but with no effect.
Is there any way to set key value ?

Copied from original issue: spring-cloud/spring-cloud-stream#602

[sabbyanandan]

From @mbogoevici on July 28, 2016 15:21

Hi,

Thanks for pointing that out. We are currently mistakingly setting the key to null always, which is not working with compacted topics.

[sabbyanandan]

From @Jacuo on August 17, 2016 7:57

Is there any prediction, when it will be fixed ?

[sabbyanandan]

@Jacuo: Could you please upgrade to Brooklyn.RELEASE and retry?

[ilayaperumalg]

Hi @Jacuo I am able to send/receive messages with key/value set with appropriate serializer/de-serializer configs. Please re-open this ticket if you still see any issue. Thanks!

[minhtran-q]

Hi @ilayaperumalg,
Can you illustrate a sample serializer/de-serializer configuration ?
Thanks