for (int key = 0; key < 10; key++)
{
ProducerRecord<String, Bytes> record =
- recordGenerator.generate(partition, Integer.toString(key%2), ++i);
+ recordGenerator.generate(partition, Integer.toString(partition*10+key%2), ++i);
kafkaProducer.send(record, (metadata, e) ->
{