Merge pull request #2671 from mmRoshani/fix-kafka-getMessage

docs: Fix kafka get message

Author: kamilmysliwiec

content/microservices/kafka.md

@@ -319,14 +319,16 @@ To access the original Kafka `IncomingMessage` object, use the `getMessage()` me
 @MessagePattern('hero.kill.dragon')
 killDragon(@Payload() message: KillDragonMessage, @Ctx() context: KafkaContext) {
   const originalMessage = context.getMessage();
-  const { headers, partition, timestamp } = originalMessage;
+  const partition = context.getPartition();
+  const { headers, timestamp } = originalMessage;
 }
 @@switch
 @Bind(Payload(), Ctx())
 @MessagePattern('hero.kill.dragon')
 killDragon(message, context) {
   const originalMessage = context.getMessage();
-  const { headers, partition, timestamp } = originalMessage;
+  const partition = context.getPartition();
+  const { headers, timestamp } = originalMessage;
 }
 ```
 
@@ -441,8 +443,9 @@ Committing offsets is essential when working with Kafka. Per default, messages w
 async handleUserCreated(@Payload() data: IncomingMessage, @Ctx() context: KafkaContext) {
   // business logic
 
-  const originalMessage = context.getMessage();
-  const { topic, partition, offset } = originalMessage;
+  const { offset } = context.getMessage();
+  const partition = context.getPartition();
+  const topic = context.getTopic();
   await this.client.commitOffsets([{ topic, partition, offset }])
 }
 @@switch
@@ -451,8 +454,9 @@ async handleUserCreated(@Payload() data: IncomingMessage, @Ctx() context: KafkaC
 async handleUserCreated(data, context) {
   // business logic
 
-  const originalMessage = context.getMessage();
-  const { topic, partition, offset } = originalMessage;
+  const { offset } = context.getMessage();
+  const partition = context.getPartition();
+  const topic = context.getTopic();
   await this.client.commitOffsets([{ topic, partition, offset }])
 }
 ```