Hi,
What Boyang meant, is this consumer config: *isolation.level, *which
default is *read_uncommitted*,
so the consumer will be able to read all messages with or without committed.
ref: https://kafka.apache.org/documentation/#consumerconfigs_isolation.level
Thanks
Luke
On Wed, Jan 27, 2021 at 2:
Have you set consumer isolation level? If it was set to uncommitted, it
will be able to see messages you produced, without commitTransaction call
On Tue, Jan 26, 2021 at 7:43 AM 积淀智慧 wrote:
> Hello, everybody,
>
>
> I'm running some tests while using Kafka transactions.
>
>
> test 1 :
> String
Hello, everybody,
I'm running some tests while using Kafka transactions.
test 1 :
String msg = "matt test";
String topic = "test";
producer.beginTransaction();
producer.send(new ProducerRecord(topic, "0", msg.toString()));
producer.send(new ProducerRecord(topic, "1", msg.toString()));
producer