From 4b7ced00624a9cda14386c3f86f919bb16f459bc Mon Sep 17 00:00:00 2001
From: Ilya Serbis <energister@users.noreply.github.com>
Date: Wed, 5 Apr 2023 14:16:26 +0300
Subject: [PATCH] Update documentation

fix code and bring it in line with the codebase
---
 docs/src/main/asciidoc/kafka/kafka_partitions.adoc | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/docs/src/main/asciidoc/kafka/kafka_partitions.adoc b/docs/src/main/asciidoc/kafka/kafka_partitions.adoc
index 728d7d656..6b53250ff 100644
--- a/docs/src/main/asciidoc/kafka/kafka_partitions.adoc
+++ b/docs/src/main/asciidoc/kafka/kafka_partitions.adoc
@@ -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);
         };
     }