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