Kafka - Pusblish message to a particalur partition for e2e testing

[authorjapps]

GIVEN a valid partition number of a topic
WHEN I load the message into the topic
THEN the message should arrive in that particular partition
AND I will will be able to assert the same by verifying the Ack.

e.g.

Asset the Ack
                    "topicPartition" : {
                        "partition" : 0,
                        "topic" : "demo-4"
                    }

the test step will look as below-

        {
            "name": "load_kafka",
            "url": "kafka-topic:demo-4",
            "operation": "produce",
            "request": {
                "records":[
                    {
                        "key": "${RANDOM.NUMBER}",
                        "value": "Hello World",
                        "partition": 0
                    }
                ]
            },
            "assertions": {
                "status" : "Ok",
                "recordMetadata" : {
                    "topicPartition" : {
                        "partition" : 0,
                        "topic" : "demo-4"
                    }
                }
            }
        }

[authorjapps]

Implementation, Dev and Test -Done.

• TODO is
  • HelloWorld
  • Wiki page on how to

[authorjapps]

Example added here to practice locally using IDE. Please start docker with kafka , before firing the test.