[jira] [Commented] (KAFKA-9462) Correct exception message in DistributedHerder

[ https://issues.apache.org/jira/browse/KAFKA-9462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17020672#comment-17020672 ] ASF GitHub Bot commented on KAFKA-9462: --- tedyu commented on pull request #7995: KAFKA-9462: Correct

[jira] [Created] (KAFKA-9462) Correct exception message in DistributedHerder

Ted Yu created KAFKA-9462: - Summary: Correct exception message in DistributedHerder Key: KAFKA-9462 URL: https://issues.apache.org/jira/browse/KAFKA-9462 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-8733) Offline partitions occur when leader's disk is slow in reads while responding to follower fetch requests.

[ https://issues.apache.org/jira/browse/KAFKA-8733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17020743#comment-17020743 ] Satish Duggana commented on KAFKA-8733: --- [~flavr] Thanks for letting us know that you are also

[jira] [Commented] (KAFKA-9113) Clean up task management

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

[jira] [Commented] (KAFKA-9355) RocksDB statistics are removed from JMX when EOS enabled and empty local state dir

[ https://issues.apache.org/jira/browse/KAFKA-9355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17020733#comment-17020733 ] Bruno Cadonna commented on KAFKA-9355: -- The cause of the bug is the following. In EOS when the a

[jira] [Comment Edited] (KAFKA-8532) controller-event-thread deadlock with zk-session-expiry-handler0

[ https://issues.apache.org/jira/browse/KAFKA-8532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17020027#comment-17020027 ] leibo edited comment on KAFKA-8532 at 1/22/20 12:56 AM: [~junrao] I do a further

[jira] [Commented] (KAFKA-9355) RocksDB statistics are removed from JMX when EOS enabled and empty local state dir

[ https://issues.apache.org/jira/browse/KAFKA-9355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17020731#comment-17020731 ] ASF GitHub Bot commented on KAFKA-9355: --- cadonna commented on pull request #7996: KAFKA-9355: Fix

[jira] [Created] (KAFKA-9463) Transient failure in KafkaAdminClientTest.testListOffsets

Ted Yu created KAFKA-9463: - Summary: Transient failure in KafkaAdminClientTest.testListOffsets Key: KAFKA-9463 URL: https://issues.apache.org/jira/browse/KAFKA-9463 Project: Kafka Issue Type: Test

[jira] [Commented] (KAFKA-7204) MockConsumer poll clears all records in poll(), including records for subscriptions that are paused.

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

[jira] [Commented] (KAFKA-9083) Various parsing issues in Values class

[ https://issues.apache.org/jira/browse/KAFKA-9083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17020510#comment-17020510 ] ASF GitHub Bot commented on KAFKA-9083: --- rhauch commented on pull request #7593: KAFKA-9083:

[jira] [Assigned] (KAFKA-9083) Various parsing issues in Values class

[ https://issues.apache.org/jira/browse/KAFKA-9083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch reassigned KAFKA-9083: Assignee: Chris Egerton > Various parsing issues in Values class >

[jira] [Assigned] (KAFKA-9427) StateRestoreListener.onRestoreEnd should report actual message count

[ https://issues.apache.org/jira/browse/KAFKA-9427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-9427: Assignee: Guozhang Wang > StateRestoreListener.onRestoreEnd should report actual message

[jira] [Commented] (KAFKA-9427) StateRestoreListener.onRestoreEnd should report actual message count

[ https://issues.apache.org/jira/browse/KAFKA-9427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17020529#comment-17020529 ] Guozhang Wang commented on KAFKA-9427: -- Will do this as part of the KAFKA-9113 cleanup. >

[jira] [Updated] (KAFKA-9083) Various parsing issues in Values class

[ https://issues.apache.org/jira/browse/KAFKA-9083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-9083: - Fix Version/s: 2.4.1 2.3.2 2.5.0 2.2.3

[jira] [Commented] (KAFKA-9458) Kafka crashed in windows environment

[ https://issues.apache.org/jira/browse/KAFKA-9458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17020534#comment-17020534 ] hirik commented on KAFKA-9458: -- [~manme...@gmail.com], I looked at the code, if somebody could help me to

[jira] [Resolved] (KAFKA-9083) Various parsing issues in Values class

[ https://issues.apache.org/jira/browse/KAFKA-9083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch resolved KAFKA-9083. -- Reviewer: Randall Hauch Resolution: Fixed Merged to the `trunk`, `2.4`, `2.3`, and `2.2`

[jira] [Commented] (KAFKA-9024) org.apache.kafka.connect.transforms.ValueToKey throws NPE

[ https://issues.apache.org/jira/browse/KAFKA-9024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17020541#comment-17020541 ] ASF GitHub Bot commented on KAFKA-9024: --- rhauch commented on pull request #7819: KAFKA-9024: Better

[jira] [Updated] (KAFKA-9024) org.apache.kafka.connect.transforms.ValueToKey throws NPE

[ https://issues.apache.org/jira/browse/KAFKA-9024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-9024: - Fix Version/s: 2.4.1 2.3.2 2.5.0 2.2.3

[jira] [Resolved] (KAFKA-9024) org.apache.kafka.connect.transforms.ValueToKey throws NPE

[ https://issues.apache.org/jira/browse/KAFKA-9024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch resolved KAFKA-9024. -- Reviewer: Randall Hauch Resolution: Fixed Merged to `trunk` and backported to the `2.4`,

[jira] [Commented] (KAFKA-9143) DistributedHerder misleadingly log error on connector task reconfiguration

[ https://issues.apache.org/jira/browse/KAFKA-9143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17020558#comment-17020558 ] ASF GitHub Bot commented on KAFKA-9143: --- rhauch commented on pull request #7648: KAFKA-9143: Log

[jira] [Updated] (KAFKA-9143) DistributedHerder misleadingly log error on connector task reconfiguration

[ https://issues.apache.org/jira/browse/KAFKA-9143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-9143: - Fix Version/s: 2.4.1 2.3.2 2.5.0 2.2.3

[jira] [Commented] (KAFKA-8532) controller-event-thread deadlock with zk-session-expiry-handler0

[ https://issues.apache.org/jira/browse/KAFKA-8532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17020027#comment-17020027 ] leibo commented on KAFKA-8532: -- {code:java} //代码占位符 public enum States { CONNECTING, ASSOCIATING,

[jira] [Comment Edited] (KAFKA-8532) controller-event-thread deadlock with zk-session-expiry-handler0

[ https://issues.apache.org/jira/browse/KAFKA-8532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17019851#comment-17019851 ] leibo edited comment on KAFKA-8532 at 1/21/20 8:24 AM: --- [~junrao]  I'm agree with

[jira] [Comment Edited] (KAFKA-8532) controller-event-thread deadlock with zk-session-expiry-handler0

[ https://issues.apache.org/jira/browse/KAFKA-8532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17020027#comment-17020027 ] leibo edited comment on KAFKA-8532 at 1/21/20 8:49 AM: --- zk client heartbeat thread

[jira] [Comment Edited] (KAFKA-8532) controller-event-thread deadlock with zk-session-expiry-handler0

[ https://issues.apache.org/jira/browse/KAFKA-8532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17020027#comment-17020027 ] leibo edited comment on KAFKA-8532 at 1/21/20 8:51 AM: --- [~junrao] I do a further

[jira] [Commented] (KAFKA-8733) Offline partitions occur when leader's disk is slow in reads while responding to follower fetch requests.

[ https://issues.apache.org/jira/browse/KAFKA-8733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17020083#comment-17020083 ] Flavien Raynaud commented on KAFKA-8733: We've seen offline partitions happening for the same

[jira] [Created] (KAFKA-9457) Flaky test org.apache.kafka.common.network.SelectorTest.testGracefulClose

Rajini Sivaram created KAFKA-9457: - Summary: Flaky test org.apache.kafka.common.network.SelectorTest.testGracefulClose Key: KAFKA-9457 URL: https://issues.apache.org/jira/browse/KAFKA-9457 Project:

[jira] [Commented] (KAFKA-9457) Flaky test org.apache.kafka.common.network.SelectorTest.testGracefulClose

[ https://issues.apache.org/jira/browse/KAFKA-9457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17020140#comment-17020140 ] ASF GitHub Bot commented on KAFKA-9457: --- rajinisivaram commented on pull request #7989: KAFKA-9457;

[jira] [Commented] (KAFKA-9423) Refine layout of configuration options on website and make individual settings directly linkable

[ https://issues.apache.org/jira/browse/KAFKA-9423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17020158#comment-17020158 ] Nikazu commented on KAFKA-9423: --- I personally like 2 & 3 the most, i agree, that the current format is a

[jira] [Created] (KAFKA-9458) Kafka crashed in windows environment

hirik created KAFKA-9458: Summary: Kafka crashed in windows environment Key: KAFKA-9458 URL: https://issues.apache.org/jira/browse/KAFKA-9458 Project: Kafka Issue Type: Bug Environment:

[jira] [Updated] (KAFKA-9458) Kafka crashed in windows environment

[ https://issues.apache.org/jira/browse/KAFKA-9458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hirik updated KAFKA-9458: - Affects Version/s: 2.4.0 > Kafka crashed in windows environment > > >

[jira] [Updated] (KAFKA-9458) Kafka crashed in windows environment

[ https://issues.apache.org/jira/browse/KAFKA-9458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hirik updated KAFKA-9458: - Environment: Windows Server 2019 (was: Windows 10) > Kafka crashed in windows environment >

[jira] [Updated] (KAFKA-9458) Kafka crashed in windows environment

[ https://issues.apache.org/jira/browse/KAFKA-9458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] M. Manna updated KAFKA-9458: Priority: Major (was: Blocker) > Kafka crashed in windows environment >

[jira] [Commented] (KAFKA-9458) Kafka crashed in windows environment

[ https://issues.apache.org/jira/browse/KAFKA-9458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17020166#comment-17020166 ] M. Manna commented on KAFKA-9458: - This is related to Windows's ability to block concurrent

[jira] [Commented] (KAFKA-9458) Kafka crashed in windows environment

[ https://issues.apache.org/jira/browse/KAFKA-9458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17020168#comment-17020168 ] M. Manna commented on KAFKA-9458: - [~hirik] - This is only an issue for Windows. Kafka isn't fully

[jira] [Created] (KAFKA-9459) MM2 sync topic config does work

Badai Aqrandista created KAFKA-9459: --- Summary: MM2 sync topic config does work Key: KAFKA-9459 URL: https://issues.apache.org/jira/browse/KAFKA-9459 Project: Kafka Issue Type: Bug

[jira] [Updated] (KAFKA-9459) MM2 sync topic config does not work

[ https://issues.apache.org/jira/browse/KAFKA-9459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Badai Aqrandista updated KAFKA-9459: Summary: MM2 sync topic config does not work (was: MM2 sync topic config does work) >

[jira] [Updated] (KAFKA-9459) MM2 sync topic config does not work

[ https://issues.apache.org/jira/browse/KAFKA-9459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Badai Aqrandista updated KAFKA-9459: Description: I have MM2 configured as follow: {code:java} { "name":

[jira] [Created] (KAFKA-9460) Enable TLSv1.2 by default and disable all others protocol versions

Nikolay Izhikov created KAFKA-9460: -- Summary: Enable TLSv1.2 by default and disable all others protocol versions Key: KAFKA-9460 URL: https://issues.apache.org/jira/browse/KAFKA-9460 Project: Kafka

[jira] [Updated] (KAFKA-9460) Enable TLSv1.2 by default and disable all others protocol versions

[ https://issues.apache.org/jira/browse/KAFKA-9460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nikolay Izhikov updated KAFKA-9460: --- Component/s: security > Enable TLSv1.2 by default and disable all others protocol versions >

[jira] [Updated] (KAFKA-9460) Enable TLSv1.2 by default and disable all others protocol versions

[ https://issues.apache.org/jira/browse/KAFKA-9460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nikolay Izhikov updated KAFKA-9460: --- Labels: needs-kip (was: ) > Enable TLSv1.2 by default and disable all others protocol

[jira] [Commented] (KAFKA-9458) Kafka crashed in windows environment

[ https://issues.apache.org/jira/browse/KAFKA-9458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17020215#comment-17020215 ] hirik commented on KAFKA-9458: -- [~manme...@gmail.com] thanks for the quick reply, I found the below pull

[jira] [Commented] (KAFKA-9458) Kafka crashed in windows environment

[ https://issues.apache.org/jira/browse/KAFKA-9458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17020218#comment-17020218 ] M. Manna commented on KAFKA-9458: - [~hirik] I am not sure if that was the right PR. I also see that

[jira] [Created] (KAFKA-9461) Limit DEBUG statement size when logging failed record value

Nicolas Guyomar created KAFKA-9461: -- Summary: Limit DEBUG statement size when logging failed record value Key: KAFKA-9461 URL: https://issues.apache.org/jira/browse/KAFKA-9461 Project: Kafka

[jira] [Updated] (KAFKA-9461) Limit DEBUG statement size when logging failed record value

[ https://issues.apache.org/jira/browse/KAFKA-9461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicolas Guyomar updated KAFKA-9461: --- Description: Hi, It is possible with the current implementation that we log a full record

[jira] [Commented] (KAFKA-9461) Limit DEBUG statement size when logging failed record value

[ https://issues.apache.org/jira/browse/KAFKA-9461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17020262#comment-17020262 ] Ted Yu commented on KAFKA-9461: --- Since we may not see the complete record given any threshold for size

[jira] [Resolved] (KAFKA-9457) Flaky test org.apache.kafka.common.network.SelectorTest.testGracefulClose

[ https://issues.apache.org/jira/browse/KAFKA-9457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-9457. --- Reviewer: Manikumar Resolution: Fixed > Flaky test

[jira] [Commented] (KAFKA-9457) Flaky test org.apache.kafka.common.network.SelectorTest.testGracefulClose

[ https://issues.apache.org/jira/browse/KAFKA-9457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17020313#comment-17020313 ] ASF GitHub Bot commented on KAFKA-9457: --- rajinisivaram commented on pull request #7989: KAFKA-9457;

[jira] [Commented] (KAFKA-9450) Decouple inner state flushing from committing with EOS

[ https://issues.apache.org/jira/browse/KAFKA-9450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17020489#comment-17020489 ] Matthias J. Sax commented on KAFKA-9450: For EOS, we don't write a checkpoint file, and thus we

[jira] [Updated] (KAFKA-9447) Add examples for EOS standalone and group mode under kafka/examples

[ https://issues.apache.org/jira/browse/KAFKA-9447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9447: --- Description: Although we have integration tests for EOS model, it would be best to also put them in

[jira] [Commented] (KAFKA-9423) Refine layout of configuration options on website and make individual settings directly linkable

[ https://issues.apache.org/jira/browse/KAFKA-9423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17020648#comment-17020648 ] ASF GitHub Bot commented on KAFKA-9423: --- soenkeliebau commented on pull request #251: KAFKA-9423:

[jira] [Commented] (KAFKA-9459) MM2 sync topic config does not work

[ https://issues.apache.org/jira/browse/KAFKA-9459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17020660#comment-17020660 ] Badai Aqrandista commented on KAFKA-9459: - I think this has been raised before in this comment: