[jira] [Created] (KAFKA-9596) Hanging test case `testMaxLogCompactionLag`

Jason Gustafson created KAFKA-9596: -- Summary: Hanging test case `testMaxLogCompactionLag` Key: KAFKA-9596 URL: https://issues.apache.org/jira/browse/KAFKA-9596 Project: Kafka Issue Type:

[jira] [Resolved] (KAFKA-9577) Client encountering SASL_HANDSHAKE protocol version errors on 2.5 / trunk

[ https://issues.apache.org/jira/browse/KAFKA-9577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9577. Resolution: Fixed > Client encountering SASL_HANDSHAKE protocol version errors on 2.5 /

[jira] [Commented] (KAFKA-9577) Client encountering SASL_HANDSHAKE protocol version errors on 2.5 / trunk

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

[jira] [Commented] (KAFKA-9441) Refactor commit logic

[ https://issues.apache.org/jira/browse/KAFKA-9441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17042378#comment-17042378 ] ASF GitHub Bot commented on KAFKA-9441: --- mjsax commented on pull request #8105: KAFKA-9441: Add

[jira] [Commented] (KAFKA-8037) KTable restore may load bad data

[ https://issues.apache.org/jira/browse/KAFKA-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17042347#comment-17042347 ] Sophie Blee-Goldman commented on KAFKA-8037: Right, duh, we definitely wouldn't want the

[jira] [Commented] (KAFKA-8037) KTable restore may load bad data

[ https://issues.apache.org/jira/browse/KAFKA-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17042315#comment-17042315 ] Guozhang Wang commented on KAFKA-8037: -- Not sure I fully understand... the committed offset records

[jira] [Commented] (KAFKA-4084) automated leader rebalance causes replication downtime for clusters with too many partitions

[ https://issues.apache.org/jira/browse/KAFKA-4084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17042307#comment-17042307 ] Jun Rao commented on KAFKA-4084: https://issues.apache.org/jira/browse/KAFKA-9594 identifies an issue

[jira] [Commented] (KAFKA-4084) automated leader rebalance causes replication downtime for clusters with too many partitions

[ https://issues.apache.org/jira/browse/KAFKA-4084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17042297#comment-17042297 ] James Cheng commented on KAFKA-4084: Hi   Just wanted to chime in with some of our experience on this

[jira] [Commented] (KAFKA-9593) Kafka config allows updating a nonexistent config and makes it mandatory to specify the config for further config updates

[ https://issues.apache.org/jira/browse/KAFKA-9593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17042234#comment-17042234 ] Jason Gustafson commented on KAFKA-9593: The message could be improved here, but I think the main

[jira] [Created] (KAFKA-9595) Config tool should use admin client's incremental config API

Jason Gustafson created KAFKA-9595: -- Summary: Config tool should use admin client's incremental config API Key: KAFKA-9595 URL: https://issues.apache.org/jira/browse/KAFKA-9595 Project: Kafka

[jira] [Commented] (KAFKA-9553) Transaction state loading metric does not count total loading time

[ https://issues.apache.org/jira/browse/KAFKA-9553?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17042210#comment-17042210 ] ASF GitHub Bot commented on KAFKA-9553: --- agam commented on pull request #8155: KAFKA-9553: Improve

[jira] [Commented] (KAFKA-9530) Flaky Test kafka.admin.DescribeConsumerGroupTest.testDescribeGroupWithShortInitializationTimeout

[ https://issues.apache.org/jira/browse/KAFKA-9530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17042199#comment-17042199 ] ASF GitHub Bot commented on KAFKA-9530: --- hachikuji commented on pull request #8154: KAFKA-9530; Fix

[jira] [Commented] (KAFKA-8037) KTable restore may load bad data

[ https://issues.apache.org/jira/browse/KAFKA-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17042181#comment-17042181 ] Sophie Blee-Goldman commented on KAFKA-8037: That's a good thought actually – I'm not sure

[jira] [Commented] (KAFKA-8037) KTable restore may load bad data

[ https://issues.apache.org/jira/browse/KAFKA-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17042172#comment-17042172 ] Guozhang Wang commented on KAFKA-8037: -- This is an interesting idea. As for whether that blocks on

[jira] [Commented] (KAFKA-9594) speed up the processing of LeaderAndIsrRequest

[ https://issues.apache.org/jira/browse/KAFKA-9594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17042167#comment-17042167 ] ASF GitHub Bot commented on KAFKA-9594: --- omkreddy commented on pull request #8153: KAFKA-9594: Add

[jira] [Created] (KAFKA-9594) speed up the processing of LeaderAndIsrRequest

Manikumar created KAFKA-9594: Summary: speed up the processing of LeaderAndIsrRequest Key: KAFKA-9594 URL: https://issues.apache.org/jira/browse/KAFKA-9594 Project: Kafka Issue Type: Improvement

[jira] [Updated] (KAFKA-9593) Kafka config allows updating a nonexistent config and makes it mandatory to specify the config for further config updates

[ https://issues.apache.org/jira/browse/KAFKA-9593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aishwarya Gune updated KAFKA-9593: -- Description: When using kafka-config script to update config, attempt to update a

[jira] [Updated] (KAFKA-9593) Kafka config allows updating a nonexistent config and makes it mandatory to specify the config for further config updates

[ https://issues.apache.org/jira/browse/KAFKA-9593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aishwarya Gune updated KAFKA-9593: -- Description: When using kafka-config script to update config, attempt to update a

[jira] [Updated] (KAFKA-9593) Kafka config allows updating a nonexistent config and makes it mandatory to specify the config for further config updates

[ https://issues.apache.org/jira/browse/KAFKA-9593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aishwarya Gune updated KAFKA-9593: -- Description: When using kafka-config script to update config, attempt to update a

[jira] [Commented] (KAFKA-9573) TestUpgrade system test failed on Java11.

[ https://issues.apache.org/jira/browse/KAFKA-9573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17042126#comment-17042126 ] Nikolay Izhikov commented on KAFKA-9573: Error for  {{test_id:

[jira] [Comment Edited] (KAFKA-9573) TestUpgrade system test failed on Java11.

[ https://issues.apache.org/jira/browse/KAFKA-9573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17042123#comment-17042123 ] Nikolay Izhikov edited comment on KAFKA-9573 at 2/21/20 7:28 PM: - Error

[jira] [Created] (KAFKA-9593) Kafka config allows updating a nonexistent config and makes it mandatory to specify the config for further config updates

Aishwarya Gune created KAFKA-9593: - Summary: Kafka config allows updating a nonexistent config and makes it mandatory to specify the config for further config updates Key: KAFKA-9593 URL:

[jira] [Commented] (KAFKA-9573) TestUpgrade system test failed on Java11.

[ https://issues.apache.org/jira/browse/KAFKA-9573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17042123#comment-17042123 ] Nikolay Izhikov commented on KAFKA-9573: Error for {{test_id:

[jira] [Commented] (KAFKA-9573) TestUpgrade system test failed on Java11.

[ https://issues.apache.org/jira/browse/KAFKA-9573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17042121#comment-17042121 ] Nikolay Izhikov commented on KAFKA-9573: test_upgrade.py resutls for the latest changes on JDK11.

[jira] [Created] (KAFKA-9592) Safely abort Producer transactions during application shutdown

Boyang Chen created KAFKA-9592: -- Summary: Safely abort Producer transactions during application shutdown Key: KAFKA-9592 URL: https://issues.apache.org/jira/browse/KAFKA-9592 Project: Kafka

[jira] [Commented] (KAFKA-9582) Ensure EOS task producer not through fatal error in unclean shutdown

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

[jira] [Resolved] (KAFKA-9206) Consumer should handle `CORRUPT_MESSAGE` error code in fetch response

[ https://issues.apache.org/jira/browse/KAFKA-9206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9206. Fix Version/s: 2.6.0 Resolution: Fixed > Consumer should handle `CORRUPT_MESSAGE`

[jira] [Commented] (KAFKA-9206) Consumer should handle `CORRUPT_MESSAGE` error code in fetch response

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

[jira] [Created] (KAFKA-9591) Log clearer error messages when there is an offset out of range (Client Change)

Cheng Tan created KAFKA-9591: Summary: Log clearer error messages when there is an offset out of range (Client Change) Key: KAFKA-9591 URL: https://issues.apache.org/jira/browse/KAFKA-9591 Project: Kafka

[jira] [Updated] (KAFKA-9580) Log clearer error messages when there is an offset out of range (Broker Change)

[ https://issues.apache.org/jira/browse/KAFKA-9580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Cheng Tan updated KAFKA-9580: - Summary: Log clearer error messages when there is an offset out of range (Broker Change) (was: Log

[jira] [Commented] (KAFKA-9584) Removing headers causes ConcurrentModificationException

[ https://issues.apache.org/jira/browse/KAFKA-9584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17041990#comment-17041990 ] Micah Ramos commented on KAFKA-9584: When calling context.headers() from punctuate it returns the

[jira] [Commented] (KAFKA-9552) Stream should handle OutOfSequence exception thrown from Producer

[ https://issues.apache.org/jira/browse/KAFKA-9552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17041952#comment-17041952 ] Matthias J. Sax commented on KAFKA-9552: For this case, why do we need to kill the thread at all?

[jira] [Commented] (KAFKA-9584) Removing headers causes ConcurrentModificationException

[ https://issues.apache.org/jira/browse/KAFKA-9584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17041947#comment-17041947 ] Matthias J. Sax commented on KAFKA-9584: What `ConsumerRecord` to you refer to? The `punctuate()`

[jira] [Updated] (KAFKA-9584) Removing headers causes ConcurrentModificationException

[ https://issues.apache.org/jira/browse/KAFKA-9584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9584: --- Affects Version/s: (was: 0.10.0.0) 2.0.0 > Removing headers

[jira] [Created] (KAFKA-9590) Add read-only configuration to limit number of topic partitions

Gokul Ramanan Subramanian created KAFKA-9590: Summary: Add read-only configuration to limit number of topic partitions Key: KAFKA-9590 URL: https://issues.apache.org/jira/browse/KAFKA-9590

[jira] [Commented] (KAFKA-9586) Fix errored json filename in ops documentation

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

[jira] [Resolved] (KAFKA-9586) Fix errored json filename in ops documentation

[ https://issues.apache.org/jira/browse/KAFKA-9586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-9586. -- Resolution: Fixed Issue resolved by pull request 8149 [https://github.com/apache/kafka/pull/8149] >

[jira] [Comment Edited] (KAFKA-9573) TestUpgrade system test failed on Java11.

[ https://issues.apache.org/jira/browse/KAFKA-9573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17041847#comment-17041847 ] Nikolay Izhikov edited comment on KAFKA-9573 at 2/21/20 1:16 PM: - Results

[jira] [Commented] (KAFKA-9575) "Notable changes in 2.5.0" doesn't mention ZooKeeper 3.5.7

[ https://issues.apache.org/jira/browse/KAFKA-9575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17041848#comment-17041848 ] ASF GitHub Bot commented on KAFKA-9575: --- omkreddy commented on pull request #8139: KAFKA-9575:

[jira] [Commented] (KAFKA-9573) TestUpgrade system test failed on Java11.

[ https://issues.apache.org/jira/browse/KAFKA-9573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17041847#comment-17041847 ] Nikolay Izhikov commented on KAFKA-9573: {noformat}

[jira] [Updated] (KAFKA-8001) AlterLogDirs: Fetch from future replica stalls when local replica becomes a leader

[ https://issues.apache.org/jira/browse/KAFKA-8001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-8001: --- Description: With KIP-320, fetch from follower / future replica returns 

[jira] [Updated] (KAFKA-8001) AlterLogDirs: Fetch from future replica stalls when local replica becomes a leader

[ https://issues.apache.org/jira/browse/KAFKA-8001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-8001: --- Summary: AlterLogDirs: Fetch from future replica stalls when local replica becomes a

[jira] [Updated] (KAFKA-8001) Fetch from future replica stalls when local replica becomes a leader

[ https://issues.apache.org/jira/browse/KAFKA-8001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-8001: --- Description: With KIP-320, fetch from follower / future replica returns 

[jira] [Created] (KAFKA-9589) LogValidatorTest#testLogAppendTimeNonCompressedV2 is not executed and does not pass

Stanislav Kozlovski created KAFKA-9589: -- Summary: LogValidatorTest#testLogAppendTimeNonCompressedV2 is not executed and does not pass Key: KAFKA-9589 URL: https://issues.apache.org/jira/browse/KAFKA-9589

[jira] [Commented] (KAFKA-9543) Consumer offset reset after new segment rolling

[ https://issues.apache.org/jira/browse/KAFKA-9543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17041716#comment-17041716 ] Brian Jones commented on KAFKA-9543: I think we've hit the same issue after upgrading from Kafka

[jira] [Commented] (KAFKA-9439) Add more public API tests for KafkaProducer

[ https://issues.apache.org/jira/browse/KAFKA-9439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17041714#comment-17041714 ] Xiang Zhang commented on KAFKA-9439: [~bchen225242] I have sent an email to d...@kafka.apache.org but