[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&focusedCommentId=17008004#comment-17008004 ] Jonathan Santilli commented on KAFKA-9312: -- There is a [pending PR|[https://gith

[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&focusedCommentId=17007664#comment-17007664 ] Jonathan Santilli commented on KAFKA-9312: -- Checking a little bit further seems

[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&focusedCommentId=17007335#comment-17007335 ] Jonathan Santilli edited comment on KAFKA-9312 at 1/3/20 5:39 PM: -

[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&focusedCommentId=17007335#comment-17007335 ] Jonathan Santilli edited comment on KAFKA-9312 at 1/3/20 9:19 AM: -

[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&focusedCommentId=17007335#comment-17007335 ] Jonathan Santilli edited comment on KAFKA-9312 at 1/3/20 9:18 AM: -

[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&focusedCommentId=17007335#comment-17007335 ] Jonathan Santilli edited comment on KAFKA-9312 at 1/3/20 9:18 AM: -

[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&focusedCommentId=17007335#comment-17007335 ] Jonathan Santilli edited comment on KAFKA-9312 at 1/3/20 9:18 AM: -

[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&focusedCommentId=17007335#comment-17007335 ] Jonathan Santilli commented on KAFKA-9312: -- After interacting with the code to s

[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 comp

[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&focusedCommentId=16973247#comment-16973247 ] Jonathan Santilli commented on KAFKA-8761: -- Hello [~ableegoldman] and [~mjsax]

[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&focusedCommentId=16886441#comment-16886441 ] Jonathan Santilli commented on KAFKA-8412: -- [~guozhang] also mentioned that we m

[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} Am

[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&focusedCommentId=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&focusedCommentId=16813657#comment-16813657 ] Jonathan Santilli commented on KAFKA-7656: -- Currently 2.2, we have updated from

[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&focusedCommentId=16813228#comment-16813228 ] Jonathan Santilli commented on KAFKA-7656: -- Enabling the TRACE level shows a lot

[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&focusedCommentId=16813140#comment-16813140 ] Jonathan Santilli edited comment on KAFKA-7656 at 4/9/19 8:53 AM: -

[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&focusedCommentId=16813140#comment-16813140 ] Jonathan Santilli commented on KAFKA-7656: -- Hello [~jagsancio], this is the only

[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&focusedCommentId=16812809#comment-16812809 ] Jonathan Santilli commented on KAFKA-7656: -- I facing the same issue, but just af

[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&focusedCommentId=16810713#comment-16810713 ] Jonathan Santilli commented on KAFKA-6582: -- Hello [~pogo] we are facing the same

[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&focusedCommentId=16714439#comment-16714439 ] Jonathan Santilli commented on KAFKA-7678: -- Hello [~guozhang] I can confirm the

[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&focusedCommentId=16707879#comment-16707879 ] Jonathan Santilli commented on KAFKA-7678: -- PR submitted [~mjsax] [https://gith

[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&focusedCommentId=16701647#comment-16701647 ] Jonathan Santilli commented on KAFKA-7678: -- Yes [~mjsax] , is like that, still f

[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 java.lang.NullPointe

[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 java.lang.NullPointerExce

[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 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: - 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&focusedCommentId=16700187#comment-16700187 ] Jonathan Santilli commented on KAFKA-7508: -- Kafka Brokers offer good metrics fro

[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&focusedCommentId=16699269#comment-16699269 ] Jonathan Santilli commented on KAFKA-7508: -- Hello [~sathish051] since you are us

[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&focusedCommentId=16693860#comment-16693860 ] Jonathan Santilli commented on KAFKA-7508: -- Hello Sathish Yanamala the logs show

[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&focusedCommentId=16692211#comment-16692211 ] Jonathan Santilli commented on KAFKA-4277: -- Hello [~birger],  KAFKA-7165 will so

[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&focusedCommentId=16682503#comment-16682503 ] Jonathan Santilli commented on KAFKA-6584: -- Good call [~ijuma], I have updated t

[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&focusedCommentId=16681912#comment-16681912 ] Jonathan Santilli commented on KAFKA-6584: -- Done [~omkreddy], thanks for the con

[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 > creat

[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 > Broke

[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&focusedCommentId=16681886#comment-16681886 ] Jonathan Santilli commented on KAFKA-6584: -- Yes, good call [~omkreddy], so will

[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&focusedCommentId=16681861#comment-16681861 ] Jonathan Santilli commented on KAFKA-6584: -- [~omkreddy] [~junrao] since KAFKA-71

[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&focusedCommentId=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&focusedCommentId=16668672#comment-16668672 ] Jonathan Santilli commented on KAFKA-7165: -- Thanks for your reply [~junrao] , th

[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&focusedCommentId=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&focusedCommentId=16661931#comment-16661931 ] Jonathan Santilli commented on KAFKA-7165: -- Hello Juan Rao, I would like to cont

[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 /brokers/ids/BROKE

[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&focusedCommentId=16591643#comment-16591643 ] Jonathan Santilli commented on KAFKA-7165: -- Done [~omkreddy], let's wait, thanks

[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&focusedCommentId=16587940#comment-16587940 ] Jonathan Santilli commented on KAFKA-7165: -- Hi, [~omkreddy] [~ijuma], am working

[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&focusedCommentId=16571905#comment-16571905 ] Jonathan Santilli commented on KAFKA-7165: -- Hello [~omkreddy] and [~cthunes] , t

[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&focusedCommentId=16564932#comment-16564932 ] Jonathan Santilli commented on KAFKA-7165: -- Sure [~omkreddy] , it makes sense, s

[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&focusedCommentId=16561206#comment-16561206 ] Jonathan Santilli commented on KAFKA-7165: -- Hello [~omkreddy] Before doing any

[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&focusedCommentId=16552161#comment-16552161 ] Jonathan Santilli commented on KAFKA-7165: -- Ok [~omkreddy], I will get myself fa

[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&focusedCommentId=16552070#comment-16552070 ] Jonathan Santilli commented on KAFKA-7165: -- Yes, [~omkreddy] seems to be related

[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 Zookeepe

[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