Compares 2 slices of kafka messages.

Compares 2 kafka messages.

Verifies if specified messages are in the topic.

Get messages in the topic (it will return after 10s).

Creates topics based on the array of nbPartitions param.

FullMessage creates a kafka message with more details with scheduler headers.

Creates a kafka.Message.

Creates multiple kafka.Messages.

creates a random topic name, each test got a different topic name.