[jira] [Commented] (KAFKA-6052) Windows: Consumers not polling when isolation.level=read_committed

[ https://issues.apache.org/jira/browse/KAFKA-6052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16376515#comment-16376515 ] Jason Gustafson commented on KAFKA-6052: I had one admittedly far-fetched idea. The inter-broker

[jira] [Comment Edited] (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=16376591#comment-16376591 ] Manikumar edited comment on KAFKA-6584 at 2/26/18 9:39 AM: --- Thanks for 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=16376591#comment-16376591 ] Manikumar commented on KAFKA-6584: -- Thanks for details.  looks like this is the root cause for existing

[jira] [Commented] (KAFKA-6561) Change visibility of aclMatch in SimpleAclAuthorizer to protected to allow overriding in subclasses

[ https://issues.apache.org/jira/browse/KAFKA-6561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16377307#comment-16377307 ] Ewen Cheslack-Postava commented on KAFKA-6561: -- [~sliebau] Not an area of the code I know

[jira] [Commented] (KAFKA-6555) Making state store queryable during restoration

[ https://issues.apache.org/jira/browse/KAFKA-6555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16377462#comment-16377462 ] Matthias J. Sax commented on KAFKA-6555: PR by [~asurana]:

[jira] [Commented] (KAFKA-4921) AssignedPartition should implement equals

[ https://issues.apache.org/jira/browse/KAFKA-4921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16377351#comment-16377351 ] ASF GitHub Bot commented on KAFKA-4921: --- guozhangwang closed pull request #2712: KAFKA-4921:

[jira] [Commented] (KAFKA-4920) Stamped should implement equals

[ https://issues.apache.org/jira/browse/KAFKA-4920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16377450#comment-16377450 ] ASF GitHub Bot commented on KAFKA-4920: --- guozhangwang closed pull request #2711: KAFKA-4920: Stamped

[jira] [Commented] (KAFKA-4920) Stamped should implement equals

[ https://issues.apache.org/jira/browse/KAFKA-4920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16377448#comment-16377448 ] ASF GitHub Bot commented on KAFKA-4920: --- guozhangwang opened a new pull request #4622: KAFKA-4920:

[jira] [Commented] (KAFKA-6592) NullPointerException thrown when executing ConsoleCosumer with deserializer set to `WindowedDeserializer`

[ https://issues.apache.org/jira/browse/KAFKA-6592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16377255#comment-16377255 ] Matthias J. Sax commented on KAFKA-6592: Did you try to specify the inner deserializer using

[jira] [Commented] (KAFKA-6572) kafka-consumer-groups does not reset offsets to specified datetime correctly

[ https://issues.apache.org/jira/browse/KAFKA-6572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16377300#comment-16377300 ] Matthias J. Sax commented on KAFKA-6572: Can you verify what the committed offset and what the

[jira] [Commented] (KAFKA-6572) kafka-consumer-groups does not reset offsets to specified datetime correctly

[ https://issues.apache.org/jira/browse/KAFKA-6572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16377195#comment-16377195 ] Sharon Lucas commented on KAFKA-6572: - [~huxi_2b]  No, the dry run did not give the correct

[jira] [Comment Edited] (KAFKA-5165) Kafka Logs Cleanup Not happening, Huge File Growth - Windows

[ https://issues.apache.org/jira/browse/KAFKA-5165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16377373#comment-16377373 ] Vahid Hashemian edited comment on KAFKA-5165 at 2/26/18 6:57 PM: - Have you

[jira] [Commented] (KAFKA-5165) Kafka Logs Cleanup Not happening, Huge File Growth - Windows

[ https://issues.apache.org/jira/browse/KAFKA-5165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16377373#comment-16377373 ] Vahid Hashemian commented on KAFKA-5165: Have you looked at broker logs to see if it contains any 

[jira] [Commented] (KAFKA-6588) Add a metric to monitor live log cleaner thread

[ https://issues.apache.org/jira/browse/KAFKA-6588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16377364#comment-16377364 ] Navina Ramesh commented on KAFKA-6588: -- [~wushujames] `time-since-last-run-ms` is a useful metric.

[jira] [Resolved] (KAFKA-4921) AssignedPartition should implement equals

[ https://issues.apache.org/jira/browse/KAFKA-4921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-4921. -- Resolution: Fixed Fix Version/s: 0.11.0.0 > AssignedPartition should implement equals >

[jira] [Commented] (KAFKA-5327) Console Consumer should only poll for up to max messages

[ https://issues.apache.org/jira/browse/KAFKA-5327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16377427#comment-16377427 ] ASF GitHub Bot commented on KAFKA-5327: --- hachikuji closed pull request #4546: KAFKA-5327: Console

[jira] [Resolved] (KAFKA-5327) Console Consumer should only poll for up to max messages

[ https://issues.apache.org/jira/browse/KAFKA-5327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-5327. Resolution: Fixed > Console Consumer should only poll for up to max messages >

[jira] [Commented] (KAFKA-4920) Stamped should implement equals

[ https://issues.apache.org/jira/browse/KAFKA-4920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16377724#comment-16377724 ] ASF GitHub Bot commented on KAFKA-4920: --- guozhangwang closed pull request #4622: KAFKA-4920: Stamped

[jira] [Updated] (KAFKA-1299) Standardize configs across tools

[ https://issues.apache.org/jira/browse/KAFKA-1299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-1299: --- Labels: needs-kip usability (was: usability) > Standardize configs across tools >

[jira] [Created] (KAFKA-6593) Coordinator disconnect in heartbeat thread can cause commitSync to block indefinitely

Jason Gustafson created KAFKA-6593: -- Summary: Coordinator disconnect in heartbeat thread can cause commitSync to block indefinitely Key: KAFKA-6593 URL: https://issues.apache.org/jira/browse/KAFKA-6593

[jira] [Updated] (KAFKA-6593) Coordinator disconnect in heartbeat thread can cause commitSync to block indefinitely

[ https://issues.apache.org/jira/browse/KAFKA-6593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-6593: --- Fix Version/s: 1.1.0 > Coordinator disconnect in heartbeat thread can cause commitSync to

[jira] [Resolved] (KAFKA-4920) Stamped should implement equals

[ https://issues.apache.org/jira/browse/KAFKA-4920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-4920. -- Resolution: Won't Fix > Stamped should implement equals > --- > >

[jira] [Updated] (KAFKA-6595) Kafka connect commit offset incorrectly.

[ https://issues.apache.org/jira/browse/KAFKA-6595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hanlin Liu updated KAFKA-6595: -- Description: Version: ConfluentPlatform Kafka 3.2.0 SourceTaskOffsetComitter calls commitOffset() and

[jira] [Created] (KAFKA-6595) Kafka connect commit offset incorrectly.

Hanlin Liu created KAFKA-6595: - Summary: Kafka connect commit offset incorrectly. Key: KAFKA-6595 URL: https://issues.apache.org/jira/browse/KAFKA-6595 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-6593) Coordinator disconnect in heartbeat thread can cause commitSync to block indefinitely

[ https://issues.apache.org/jira/browse/KAFKA-6593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16377764#comment-16377764 ] Jason Gustafson commented on KAFKA-6593: I was wrong about the explanation. The

[jira] [Commented] (KAFKA-6486) TimeWindows causes unordered calls to windowed aggregation functions

[ https://issues.apache.org/jira/browse/KAFKA-6486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16377860#comment-16377860 ] Asutosh Pandya commented on KAFKA-6486: --- Added patch with above mentioned change. I already have

[jira] [Comment Edited] (KAFKA-6486) TimeWindows causes unordered calls to windowed aggregation functions

[ https://issues.apache.org/jira/browse/KAFKA-6486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16377860#comment-16377860 ] Asutosh Pandya edited comment on KAFKA-6486 at 2/27/18 12:50 AM: -

[jira] [Commented] (KAFKA-6486) TimeWindows causes unordered calls to windowed aggregation functions

[ https://issues.apache.org/jira/browse/KAFKA-6486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16377760#comment-16377760 ] Guozhang Wang commented on KAFKA-6486: -- Thanks for reporting this [~vale68] I think it is a good

[jira] [Updated] (KAFKA-6486) TimeWindows causes unordered calls to windowed aggregation functions

[ https://issues.apache.org/jira/browse/KAFKA-6486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Asutosh Pandya updated KAFKA-6486: -- Attachment: KAFKA-6486.patch > TimeWindows causes unordered calls to windowed aggregation

[jira] [Created] (KAFKA-6594) 第二次启动kafka是报错00000000000000000000.timeindex: 另一个程序正在使用此文件，进程无法访问。

徐兴强 created KAFKA-6594: -- Summary: 第二次启动kafka是报错.timeindex: 另一个程序正在使用此文件，进程无法访问。 Key: KAFKA-6594 URL: https://issues.apache.org/jira/browse/KAFKA-6594 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-6195) DNS alias support for secured connections

[ https://issues.apache.org/jira/browse/KAFKA-6195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16376927#comment-16376927 ] Jonathan Skrzypek commented on KAFKA-6195: -- [~rsivaram] is this something you could help with ?

[jira] [Resolved] (KAFKA-6196) Kafka Transactional producer with broker on windows

[ https://issues.apache.org/jira/browse/KAFKA-6196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6196. Resolution: Duplicate Thanks for the patch. Marking this as a dup since it seems to be the

[jira] [Comment Edited] (KAFKA-6196) Kafka Transactional producer with broker on windows

[ https://issues.apache.org/jira/browse/KAFKA-6196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16377135#comment-16377135 ] Jason Gustafson edited comment on KAFKA-6196 at 2/26/18 4:41 PM: - Thanks

[jira] [Resolved] (KAFKA-6153) Kafka Transactional Messaging does not work on windows but on linux

[ https://issues.apache.org/jira/browse/KAFKA-6153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6153. Resolution: Duplicate Seems like the same underlying issue as KAFKA-6052. Marking as dup

[jira] [Resolved] (KAFKA-6076) Using new producer api of transaction twice failed when server run on Windows OS

[ https://issues.apache.org/jira/browse/KAFKA-6076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6076. Resolution: Duplicate Marking as dup of KAFKA-6052 since it is likely the same underlying

[jira] [Commented] (KAFKA-6052) Windows: Consumers not polling when isolation.level=read_committed

[ https://issues.apache.org/jira/browse/KAFKA-6052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16377149#comment-16377149 ] Jason Gustafson commented on KAFKA-6052: [~vmallavarapu] I looked at the logs, but they don't

[jira] [Commented] (KAFKA-6057) Users forget `--execute` in the offset reset tool

[ https://issues.apache.org/jira/browse/KAFKA-6057?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16377170#comment-16377170 ] ASF GitHub Bot commented on KAFKA-6057: --- hachikuji closed pull request #4069: KAFKA-6057: Users