SpringCloud/spring-cloud-stream
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Update documentation

Browse Source 
fix code and bring it in line with the codebase
This commit is contained in:
Ilya Serbis
2023-04-05 14:16:26 +03:00
committed by Soby Chacko
parent a01bf30d38
commit 4b7ced0062
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
docs/src/main/asciidoc/kafka/kafka_partitions.adoc
View File

@@ -74,15 +74,15 @@ public class KafkaPartitionConsumerApplication {
public static void main(String[] args) {
new SpringApplicationBuilder(KafkaPartitionConsumerApplication.class)
.web(false)
.web(WebApplicationType.NONE)
.run(args);
}
@Bean
public Consumer<Message<String>> listen() {
return message -> {
int partition =- message.getHeaders().get(KafkaHeaders.RECEIVED_PARTITION_ID);
System.out.println(in + " received from partition " + partition);
int partition = (int) message.getHeaders().get(KafkaHeaders.RECEIVED_PARTITION);
System.out.println(message + " received from partition " + partition);
};
}