Regarding the kafka sample code, currently you can only have one message key, which yo

There are several options. 1 Delete this line: <div class="snipp

See the <a href="https://github.com/spring-projects/spring-integration-kafka#outbound-

kafka: set message key dynamically about spring-integration-samples HOT 2 OPEN

spring-projects commented on June 16, 2024

kafka: set message key dynamically

from spring-integration-samples.

garyrussell commented on June 16, 2024 3

There are several options.

1 Delete this line:

handler.setMessageKeyExpression(new LiteralExpression(this.messageKey));

And change the send to ...

toKafka.send(new GenericMessage<>("foo" + i));

toKafka.send(MessageBuilder.withPayload("foo" + i)
    .setHeader(KafkaHeades.MESSAGE_KEY)
    .build());

If there is no key expression, we look for that header (same thing for the topic, partition).

2 Change this

handler.setMessageKeyExpression(new LiteralExpression(this.messageKey));

handler.setMessageKeyExpression(new SpelExpressionParser.parseExpression("<some expression>"));

Where <some expression> calculates the key - such as payload.key or headers['myHeader'].

from spring-integration-samples.

garyrussell commented on June 16, 2024

See the README.

from spring-integration-samples.