We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent e0e013e commit 55b16f1Copy full SHA for 55b16f1
spring-kafka/src/main/java/org/springframework/kafka/requestreply/ReplyingKafkaTemplate.java
@@ -114,7 +114,8 @@ else if (properties.getTopicPartitions() != null && properties.getTopicPartition
114
this.replyTopic = null;
115
this.replyPartition = null;
116
this.logger.debug("Could not determine container's reply topic/partition; senders must populate "
117
- + "at least the " + KafkaHeaders.REPLY_PARTITION + " header");
+ + "at least the " + KafkaHeaders.REPLY_TOPIC + " header, and optionally the "
118
+ + KafkaHeaders.REPLY_PARTITION + " header");
119
}
120
else {
121
this.replyTopic = replyTopic.getBytes(StandardCharsets.UTF_8);
0 commit comments