Behavior when kafka producer is network partitioned

2017-07-16 Thread Abhishek Agarwal
if kafka brokers come up or the network comes back up, connection state will remain the same. Producing messages will continue to fail till the kafka client is restarted. Is this understanding correct? -- Regards, Abhishek Agarwal

Re: Behavior when kafka producer is network partitioned

2017-07-17 Thread Abhishek Agarwal
On Sun, Jul 16, 2017 at 8:32 PM, Abhishek Agarwal wrote: > What is the behaviour in 0.10.x if kafka producer is not able to reach any > of the broker for a brief duration? > > From what I understand from the code, all the nodes will be in > disconnected state. Since there is no n

Re: kafka.log:type=LogFlushStats,name=LogFlushRateAndTimeMs Not Reported

2017-01-03 Thread Abhishek Agarwal
g:type=LogFlushStats,name=LogFlushRateAndTimeMs" > Am I missing anything? > > I have set up the log flush time as 60000 > > Thanks, > -- Regards, Abhishek Agarwal

Re: [DISCUSS] KIP-82 - Add Record Headers

2017-03-11 Thread Abhishek Agarwal
Bumping up this thread. Is there a final verdict on this KIP? On Sat, Dec 3, 2016 at 2:29 AM, Gwen Shapira wrote: > Woah, I wasn't aware this is something we'll do. It wasn't in the KIP, > right? > > I guess we could do it the same way ACLs currently work. > I had in mind something that will all

[jira] [Created] (KAFKA-7024) Rocksdb state directory should be created before opening the DB

2018-06-08 Thread Abhishek Agarwal (JIRA)
Abhishek Agarwal created KAFKA-7024: --- Summary: Rocksdb state directory should be created before opening the DB Key: KAFKA-7024 URL: https://issues.apache.org/jira/browse/KAFKA-7024 Project: Kafka

[jira] [Created] (KAFKA-7213) NullPointerException during state restoration in kafka streams

2018-07-27 Thread Abhishek Agarwal (JIRA)
Abhishek Agarwal created KAFKA-7213: --- Summary: NullPointerException during state restoration in kafka streams Key: KAFKA-7213 URL: https://issues.apache.org/jira/browse/KAFKA-7213 Project: Kafka