[jira] [Commented] (KAFKA-9312) KafkaProducer flush behavior does not guarantee completed sends under record batch splitting

[ https://issues.apache.org/jira/browse/KAFKA-9312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17008004#comment-17008004 ] Jonathan Santilli commented on KAFKA-9312: -- There is a [pending

[jira] [Commented] (KAFKA-9312) KafkaProducer flush behavior does not guarantee completed sends under record batch splitting

[ https://issues.apache.org/jira/browse/KAFKA-9312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17007664#comment-17007664 ] Jonathan Santilli commented on KAFKA-9312: -- Checking a little bit further seems like yes, it

[jira] [Comment Edited] (KAFKA-9312) KafkaProducer flush behavior does not guarantee completed sends under record batch splitting

[ https://issues.apache.org/jira/browse/KAFKA-9312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17007335#comment-17007335 ] Jonathan Santilli edited comment on KAFKA-9312 at 1/3/20 5:39 PM: -- After

[jira] [Comment Edited] (KAFKA-9312) KafkaProducer flush behavior does not guarantee completed sends under record batch splitting

[ https://issues.apache.org/jira/browse/KAFKA-9312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17007335#comment-17007335 ] Jonathan Santilli edited comment on KAFKA-9312 at 1/3/20 9:19 AM: -- After

[jira] [Comment Edited] (KAFKA-9312) KafkaProducer flush behavior does not guarantee completed sends under record batch splitting

[ https://issues.apache.org/jira/browse/KAFKA-9312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17007335#comment-17007335 ] Jonathan Santilli edited comment on KAFKA-9312 at 1/3/20 9:18 AM: -- After

[jira] [Comment Edited] (KAFKA-9312) KafkaProducer flush behavior does not guarantee completed sends under record batch splitting

[ https://issues.apache.org/jira/browse/KAFKA-9312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17007335#comment-17007335 ] Jonathan Santilli edited comment on KAFKA-9312 at 1/3/20 9:18 AM: -- After

[jira] [Comment Edited] (KAFKA-9312) KafkaProducer flush behavior does not guarantee completed sends under record batch splitting

[ https://issues.apache.org/jira/browse/KAFKA-9312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17007335#comment-17007335 ] Jonathan Santilli edited comment on KAFKA-9312 at 1/3/20 9:18 AM: -- After

[jira] [Commented] (KAFKA-9312) KafkaProducer flush behavior does not guarantee completed sends under record batch splitting

[ https://issues.apache.org/jira/browse/KAFKA-9312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17007335#comment-17007335 ] Jonathan Santilli commented on KAFKA-9312: -- After interacting with the code to solve the issue

[jira] [Assigned] (KAFKA-9312) KafkaProducer flush behavior does not guarantee completed sends under record batch splitting

[ https://issues.apache.org/jira/browse/KAFKA-9312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jonathan Santilli reassigned KAFKA-9312: Assignee: Jonathan Santilli > KafkaProducer flush behavior does not guarantee

[jira] [Commented] (KAFKA-8761) Flaky Test AdminClientIntegrationTest.testIncrementalAlterConfigsForLog4jLogLevels

[ https://issues.apache.org/jira/browse/KAFKA-8761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16973247#comment-16973247 ] Jonathan Santilli commented on KAFKA-8761: -- Hello [~ableegoldman] and [~mjsax] I have tried to

[jira] [Commented] (KAFKA-8412) Still a nullpointer exception thrown on shutdown while flushing before closing producers

[ https://issues.apache.org/jira/browse/KAFKA-8412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16886441#comment-16886441 ] Jonathan Santilli commented on KAFKA-8412: -- [~guozhang] also mentioned that we may need to

[jira] [Updated] (KAFKA-8615) Change to track partition time breaks TimestampExtractor

[ https://issues.apache.org/jira/browse/KAFKA-8615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jonathan Santilli updated KAFKA-8615: - Description: >From the users mailing list, *UPDATED* by Jonathan Santilli: {noformat}

[jira] [Comment Edited] (KAFKA-7656) ReplicaManager fetch fails on leader due to long/integer overflow

[ https://issues.apache.org/jira/browse/KAFKA-7656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16813657#comment-16813657 ] Jonathan Santilli edited comment on KAFKA-7656 at 4/9/19 5:38 PM: --

[jira] [Commented] (KAFKA-7656) ReplicaManager fetch fails on leader due to long/integer overflow

[ https://issues.apache.org/jira/browse/KAFKA-7656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16813657#comment-16813657 ] Jonathan Santilli commented on KAFKA-7656: -- Currently 2.2, we have updated from 2.0 recently.

[jira] [Comment Edited] (KAFKA-7656) ReplicaManager fetch fails on leader due to long/integer overflow

[ https://issues.apache.org/jira/browse/KAFKA-7656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16813140#comment-16813140 ] Jonathan Santilli edited comment on KAFKA-7656 at 4/9/19 8:53 AM: -- Hello

[jira] [Commented] (KAFKA-7656) ReplicaManager fetch fails on leader due to long/integer overflow

[ https://issues.apache.org/jira/browse/KAFKA-7656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16813140#comment-16813140 ] Jonathan Santilli commented on KAFKA-7656: -- Hello [~jagsancio], this is the only log I see (on

[jira] [Commented] (KAFKA-7656) ReplicaManager fetch fails on leader due to long/integer overflow

[ https://issues.apache.org/jira/browse/KAFKA-7656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16812809#comment-16812809 ] Jonathan Santilli commented on KAFKA-7656: -- I facing the same issue, but just after updating

[jira] [Commented] (KAFKA-6582) Partitions get underreplicated, with a single ISR, and doesn't recover. Other brokers do not take over and we need to manually restart the broker.

[ https://issues.apache.org/jira/browse/KAFKA-6582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16810713#comment-16810713 ] Jonathan Santilli commented on KAFKA-6582: -- Hello [~pogo] we are facing the same issue in

[jira] [Commented] (KAFKA-7678) Failed to close producer due to java.lang.NullPointerException

[ https://issues.apache.org/jira/browse/KAFKA-7678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16714439#comment-16714439 ] Jonathan Santilli commented on KAFKA-7678: -- Hello [~guozhang] I can confirm the issue about

[jira] [Commented] (KAFKA-7678) Failed to close producer due to java.lang.NullPointerException

[ https://issues.apache.org/jira/browse/KAFKA-7678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16707879#comment-16707879 ] Jonathan Santilli commented on KAFKA-7678: -- PR submitted [~mjsax]

[jira] [Commented] (KAFKA-7678) Failed to close producer due to java.lang.NullPointerException

[ https://issues.apache.org/jira/browse/KAFKA-7678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16701647#comment-16701647 ] Jonathan Santilli commented on KAFKA-7678: -- Yes [~mjsax] , is like that, still finished

[jira] [Assigned] (KAFKA-7678) Failed to close producer due to java.lang.NullPointerException

[ https://issues.apache.org/jira/browse/KAFKA-7678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jonathan Santilli reassigned KAFKA-7678: Assignee: Jonathan Santilli > Failed to close producer due to

[jira] [Updated] (KAFKA-7678) Failed to close producer due to java.lang.NullPointerException

[ https://issues.apache.org/jira/browse/KAFKA-7678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jonathan Santilli updated KAFKA-7678: - Priority: Minor (was: Major) > Failed to close producer due to

[jira] [Resolved] (KAFKA-7508) Kafka broker anonymous disconnected from Zookeeper

[ https://issues.apache.org/jira/browse/KAFKA-7508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jonathan Santilli resolved KAFKA-7508. -- Resolution: Not A Problem Closed since was requested by the reported. Sathish agree

[jira] [Updated] (KAFKA-7678) Failed to close producer due to java.lang.NullPointerException

[ https://issues.apache.org/jira/browse/KAFKA-7678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jonathan Santilli updated KAFKA-7678: - Description: This occurs when the group is rebalancing in a Kafka Stream application and

[jira] [Created] (KAFKA-7678) Failed to close producer due to java.lang.NullPointerException

Jonathan Santilli created KAFKA-7678: Summary: Failed to close producer due to java.lang.NullPointerException Key: KAFKA-7678 URL: https://issues.apache.org/jira/browse/KAFKA-7678 Project: Kafka

[jira] [Commented] (KAFKA-7508) Kafka broker anonymous disconnected from Zookeeper

[ https://issues.apache.org/jira/browse/KAFKA-7508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16700187#comment-16700187 ] Jonathan Santilli commented on KAFKA-7508: -- Kafka Brokers offer good metrics from JMX, you can

[jira] [Commented] (KAFKA-7508) Kafka broker anonymous disconnected from Zookeeper

[ https://issues.apache.org/jira/browse/KAFKA-7508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16699269#comment-16699269 ] Jonathan Santilli commented on KAFKA-7508: -- Hello [~sathish051] since you are using Java 8, have

[jira] [Commented] (KAFKA-7508) Kafka broker anonymous disconnected from Zookeeper

[ https://issues.apache.org/jira/browse/KAFKA-7508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16693860#comment-16693860 ] Jonathan Santilli commented on KAFKA-7508: -- Hello Sathish Yanamala the logs show a clear

[jira] [Commented] (KAFKA-4277) creating ephemeral node already exist

[ https://issues.apache.org/jira/browse/KAFKA-4277?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16692211#comment-16692211 ] Jonathan Santilli commented on KAFKA-4277: -- Hello [~birger],  KAFKA-7165 will solve the 

[jira] [Commented] (KAFKA-6584) Session expiration concurrent with ZooKeeper leadership failover may lead to broker registration failure

[ https://issues.apache.org/jira/browse/KAFKA-6584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16682503#comment-16682503 ] Jonathan Santilli commented on KAFKA-6584: -- Good call [~ijuma], I have updated the description

[jira] [Updated] (KAFKA-6584) Session expiration concurrent with ZooKeeper leadership failover may lead to broker registration failure

[ https://issues.apache.org/jira/browse/KAFKA-6584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jonathan Santilli updated KAFKA-6584: - Description: It seems that an edge case exists which can lead to sessions "un-expiring"

[jira] [Commented] (KAFKA-6584) Session expiration concurrent with ZooKeeper leadership failover may lead to broker registration failure

[ https://issues.apache.org/jira/browse/KAFKA-6584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681912#comment-16681912 ] Jonathan Santilli commented on KAFKA-6584: -- Done [~omkreddy], thanks for the confirmation. >

[jira] [Resolved] (KAFKA-4277) creating ephemeral node already exist

[ https://issues.apache.org/jira/browse/KAFKA-4277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jonathan Santilli resolved KAFKA-4277. -- Resolution: Duplicate This is getting closed since KAFKA-7165 have been solved >

[jira] [Resolved] (KAFKA-5971) Broker keeps running even though not registered in ZK

[ https://issues.apache.org/jira/browse/KAFKA-5971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jonathan Santilli resolved KAFKA-5971. -- Resolution: Duplicate This is getting closed since KAFKA-7165 have been solved >

[jira] [Commented] (KAFKA-6584) Session expiration concurrent with ZooKeeper leadership failover may lead to broker registration failure

[ https://issues.apache.org/jira/browse/KAFKA-6584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681886#comment-16681886 ] Jonathan Santilli commented on KAFKA-6584: -- Yes, good call [~omkreddy], so will be closing as

[jira] [Commented] (KAFKA-6584) Session expiration concurrent with ZooKeeper leadership failover may lead to broker registration failure

[ https://issues.apache.org/jira/browse/KAFKA-6584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16681861#comment-16681861 ] Jonathan Santilli commented on KAFKA-6584: -- [~omkreddy] [~junrao] since KAFKA-7165 has been

[jira] [Comment Edited] (KAFKA-7165) Error while creating ephemeral at /brokers/ids/BROKER_ID

[ https://issues.apache.org/jira/browse/KAFKA-7165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668672#comment-16668672 ] Jonathan Santilli edited comment on KAFKA-7165 at 10/30/18 12:59 PM: -

[jira] [Commented] (KAFKA-7165) Error while creating ephemeral at /brokers/ids/BROKER_ID

[ https://issues.apache.org/jira/browse/KAFKA-7165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668672#comment-16668672 ] Jonathan Santilli commented on KAFKA-7165: -- Thanks for your reply [~junrao] , that was the only

[jira] [Comment Edited] (KAFKA-7165) Error while creating ephemeral at /brokers/ids/BROKER_ID

[ https://issues.apache.org/jira/browse/KAFKA-7165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16661931#comment-16661931 ] Jonathan Santilli edited comment on KAFKA-7165 at 10/24/18 8:31 AM:

[jira] [Commented] (KAFKA-7165) Error while creating ephemeral at /brokers/ids/BROKER_ID

[ https://issues.apache.org/jira/browse/KAFKA-7165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16661931#comment-16661931 ] Jonathan Santilli commented on KAFKA-7165: -- Hello Juan Rao, I would like to continue working on

[jira] [Assigned] (KAFKA-7165) Error while creating ephemeral at /brokers/ids/BROKER_ID

[ https://issues.apache.org/jira/browse/KAFKA-7165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jonathan Santilli reassigned KAFKA-7165: Assignee: Jonathan Santilli > Error while creating ephemeral at

[jira] [Commented] (KAFKA-7165) Error while creating ephemeral at /brokers/ids/BROKER_ID

[ https://issues.apache.org/jira/browse/KAFKA-7165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16591643#comment-16591643 ] Jonathan Santilli commented on KAFKA-7165: -- Done [~omkreddy], let's wait, thanks! > Error while

[jira] [Commented] (KAFKA-7165) Error while creating ephemeral at /brokers/ids/BROKER_ID

[ https://issues.apache.org/jira/browse/KAFKA-7165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16571905#comment-16571905 ] Jonathan Santilli commented on KAFKA-7165: -- Hello [~omkreddy] and [~cthunes] , thanks a lot for

[jira] [Commented] (KAFKA-7165) Error while creating ephemeral at /brokers/ids/BROKER_ID

[ https://issues.apache.org/jira/browse/KAFKA-7165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16564932#comment-16564932 ] Jonathan Santilli commented on KAFKA-7165: -- Sure [~omkreddy] , it makes sense, some

[jira] [Commented] (KAFKA-7165) Error while creating ephemeral at /brokers/ids/BROKER_ID

[ https://issues.apache.org/jira/browse/KAFKA-7165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16552161#comment-16552161 ] Jonathan Santilli commented on KAFKA-7165: -- Ok [~omkreddy], I will get myself familiarized with

[jira] [Commented] (KAFKA-7165) Error while creating ephemeral at /brokers/ids/BROKER_ID

[ https://issues.apache.org/jira/browse/KAFKA-7165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16552070#comment-16552070 ] Jonathan Santilli commented on KAFKA-7165: -- Yes, [~omkreddy] seems to be related, do you know

[jira] [Updated] (KAFKA-7165) Error while creating ephemeral at /brokers/ids/BROKER_ID

[ https://issues.apache.org/jira/browse/KAFKA-7165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jonathan Santilli updated KAFKA-7165: - Description: Kafka version: 1.1.0 Zookeeper version: 3.4.12 4 Kafka Brokers 4

[jira] [Created] (KAFKA-7165) Error while creating ephemeral at /brokers/ids/BROKER_ID

Jonathan Santilli created KAFKA-7165: Summary: Error while creating ephemeral at /brokers/ids/BROKER_ID Key: KAFKA-7165 URL: https://issues.apache.org/jira/browse/KAFKA-7165 Project: Kafka