ducer.beginTransaction();
ProducerRecord record = new
ProducerRecord<>("test", 0, (long) 0, Long.toString(0));
producer.send(record);
producer.commitTransaction();
producer.beginTransaction();
record = new ProducerRecord<>("test", 0, (long)0
Hello,
I was testing the transactional message on kafka.
but I get a problem.
the producer always blocking at second commitTransaction.
Here is my code:
Properties kafkaProps = new Properties();
kafkaProps.setProperty("bootstrap.servers", "localhost:9092");
kafkaProps.set
