Re: Reg. Kafka transactional producer and consumer

2017-11-08 Thread Apurva Mehta
00000000.timeindex > > Index timestamp: 0, Previously indexed timestamp: 0 > > > > > > From: Matthias J. Sax > Sent: Saturday, November 4, 2017 8:11:07 PM > To: users@kafka.apache.org > Subject: Re: Reg. Kafka transactional

Re: Reg. Kafka transactional producer and consumer

2017-11-06 Thread Abhishek Verma
\.timeindex Index timestamp: 0, Previously indexed timestamp: 0 From: Matthias J. Sax Sent: Saturday, November 4, 2017 8:11:07 PM To: users@kafka.apache.org Subject: Re: Reg. Kafka transactional producer and consumer Hi, this consumer log

Re: Reg. Kafka transactional producer and consumer

2017-11-04 Thread Matthias J. Sax
Hi, this consumer log line indicates that there is an open/pending transaction (ie, neither committed nor aborted) and thus, the broker does not deliver the data to the consumer. -> highWaterMark = 5, but lastStableOffset = 0 On 11/2/17 5:25 AM, Abhishek Verma wrote: > 1871 [main] DEBUG org.apa

Reg. Kafka transactional producer and consumer

2017-11-01 Thread Abhishek Verma
Hi All, I am trying to make a hello world example for Transactional Producer and trying to consume. I am doing all this in plain java. I can produce but consumer is not consuming message. I searched over other places and I found some people have same problem. Right now, I am using single brok