SimpleProducer instanceA = new SimpleProducer(
bootstrapServers,
TOPIC,
- "FOO");
+ "FOO",
+ "A");
instanceA.begin();
CompletableFuture<Long> resultA1 = instanceA.send("a","message #1");
SimpleProducer instanceB = new SimpleProducer(
bootstrapServers,
TOPIC,
- "FOO");
+ "FOO",
+ "B");
instanceB.begin();
CompletableFuture<Long> resultB1 = instanceB.send("b","message #1");