diff --git a/spring-kafka-docs/src/main/antora/modules/ROOT/pages/kafka/receiving-messages/listener-annotation.adoc b/spring-kafka-docs/src/main/antora/modules/ROOT/pages/kafka/receiving-messages/listener-annotation.adoc index 8cbbd01570..8023e4aa67 100644 --- a/spring-kafka-docs/src/main/antora/modules/ROOT/pages/kafka/receiving-messages/listener-annotation.adoc +++ b/spring-kafka-docs/src/main/antora/modules/ROOT/pages/kafka/receiving-messages/listener-annotation.adoc @@ -209,7 +209,7 @@ The following example shows how to use the headers: [source, java] ---- -@KafkaListener(id = "qux", topicPattern = "myTopic1") +@KafkaListener(id = "qux", topics = "myTopic1") public void listen(@Payload String foo, @Header(name = KafkaHeaders.RECEIVED_KEY, required = false) Integer key, @Header(KafkaHeaders.RECEIVED_PARTITION) int partition, diff --git a/spring-kafka-docs/src/main/antora/modules/ROOT/pages/kafka/receiving-messages/listener-group-id.adoc b/spring-kafka-docs/src/main/antora/modules/ROOT/pages/kafka/receiving-messages/listener-group-id.adoc index 6a46c34da1..281463e0ed 100644 --- a/spring-kafka-docs/src/main/antora/modules/ROOT/pages/kafka/receiving-messages/listener-group-id.adoc +++ b/spring-kafka-docs/src/main/antora/modules/ROOT/pages/kafka/receiving-messages/listener-group-id.adoc @@ -9,7 +9,7 @@ Alternatively, you can access the group id in a method parameter. [source, java] ---- -@KafkaListener(id = "id", topicPattern = "someTopic") +@KafkaListener(id = "id", topics = "someTopic") public void listener(@Payload String payload, @Header(KafkaHeaders.GROUP_ID) String groupId) { ... }