Re: Kafka transactions commit message consumability issues
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:50 AM Boyang Chen wrote: > 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 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.send(new ProducerRecord(topic, "2", msg.toString())); > > for (; ; ) { } > > > > > > test result:Messages also arrive at the consumer without delay. > > > > > > My question is, why can data be committed without commitTransaction. > > > > > > thx > > > > > > > > > > > > > > > > > > > > > > > > > > > > >
Re: Kafka transactions commit message consumability issues
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 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.send(new ProducerRecord(topic, "2", msg.toString())); > for (; ; ) { } > > > test result:Messages also arrive at the consumer without delay. > > > My question is, why can data be committed without commitTransaction. > > > thx > > > > > > > > > > > > > >
Kafka transactions commit message consumability issues
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.send(new ProducerRecord(topic, "2", msg.toString())); for (; ; ) { } test result:Messages also arrive at the consumer without delay. My question is, why can data be committed without commitTransaction. thx