Skip to content

Commit 5f1b1a5

Browse files
Fix KafkaListenerEndpoint#getEndpointDescription
Add a missing left quote in `AbstractKafkaListenerEndpoint.getEndpointDescription()` for `topics`
1 parent b9edbfd commit 5f1b1a5

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

spring-kafka/src/main/java/org/springframework/kafka/config/AbstractKafkaListenerEndpoint.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -560,7 +560,7 @@ private void setupMessageListener(MessageListenerContainer container,
560560
protected StringBuilder getEndpointDescription() {
561561
StringBuilder result = new StringBuilder();
562562
return result.append(getClass().getSimpleName()).append("[").append(this.id).
563-
append("] topics=").append(this.topics).
563+
append("] topics='").append(this.topics).
564564
append("' | topicPartitions='").append(this.topicPartitions).
565565
append("' | topicPattern='").append(this.topicPattern).append("'");
566566
}

0 commit comments

Comments
 (0)