[jira] [Commented] (KAFKA-9612) CLI Dynamic Configuration with file input

[ https://issues.apache.org/jira/browse/KAFKA-9612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17047261#comment-17047261 ] sats commented on KAFKA-9612: - [~aneel]  KPI wiki don't have the mailing discussion link. > CLI Dynamic

[jira] [Commented] (KAFKA-8784) Remove default implementation of RocksDBConfigSetter#close

[ https://issues.apache.org/jira/browse/KAFKA-8784?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17047258#comment-17047258 ] sats commented on KAFKA-8784: - [~ableegoldman] / [~mjsax] can i take-up this ? > Remove default

[jira] [Reopened] (KAFKA-8460) Flaky Test PlaintextConsumerTest#testLowMaxFetchSizeForRequestAndPartition

[ https://issues.apache.org/jira/browse/KAFKA-8460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reopened KAFKA-8460: > Flaky Test PlaintextConsumerTest#testLowMaxFetchSizeForRequestAndPartition >

[jira] [Commented] (KAFKA-8460) Flaky Test PlaintextConsumerTest#testLowMaxFetchSizeForRequestAndPartition

[ https://issues.apache.org/jira/browse/KAFKA-8460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17047203#comment-17047203 ] Boyang Chen commented on KAFKA-8460: Test failed again:  {code:java} Error

[jira] [Commented] (KAFKA-9620) Task revocation failure could introduce remaining unclean tasks

[ https://issues.apache.org/jira/browse/KAFKA-9620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17047176#comment-17047176 ] Sophie Blee-Goldman commented on KAFKA-9620: [~guozhang] I agree with your second

[jira] [Updated] (KAFKA-9362) Missing GC logs when running Kafka with Java 11 with OpenJ9 VM

[ https://issues.apache.org/jira/browse/KAFKA-9362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Arthur updated KAFKA-9362: Fix Version/s: (was: 2.5.0) > Missing GC logs when running Kafka with Java 11 with OpenJ9 VM >

[jira] [Updated] (KAFKA-9605) EOS Producer could throw illegal state if trying to complete a failed batch after fatal error

[ https://issues.apache.org/jira/browse/KAFKA-9605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Arthur updated KAFKA-9605: Fix Version/s: (was: 2.5.0) 2.6.0 > EOS Producer could throw illegal state

[jira] [Updated] (KAFKA-8869) Map taskConfigs in KafkaConfigBackingStore grows monotonically despite of task removals

[ https://issues.apache.org/jira/browse/KAFKA-8869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Arthur updated KAFKA-8869: Fix Version/s: (was: 2.5.0) 2.6.0 > Map taskConfigs in

[jira] [Commented] (KAFKA-9623) Streams will attempt to commit during shutdown if rebalance is in progress

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

[jira] [Created] (KAFKA-9623) Streams will attempt to commit during shutdown if rebalance is in progress

Guozhang Wang created KAFKA-9623: Summary: Streams will attempt to commit during shutdown if rebalance is in progress Key: KAFKA-9623 URL: https://issues.apache.org/jira/browse/KAFKA-9623 Project:

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

[ https://issues.apache.org/jira/browse/KAFKA-9592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17047122#comment-17047122 ] Boyang Chen commented on KAFKA-9592: Thanks for taking a look [~iamabug] ! Feel free to take 5604 as

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

[ https://issues.apache.org/jira/browse/KAFKA-9592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17047100#comment-17047100 ] Guozhang Wang edited comment on KAFKA-9592 at 2/28/20 1:03 AM: --- That's a

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

[ https://issues.apache.org/jira/browse/KAFKA-9592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17047100#comment-17047100 ] Guozhang Wang commented on KAFKA-9592: -- That's a good question -- if we are certain KAFKA-5606 is

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

[ https://issues.apache.org/jira/browse/KAFKA-9592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17047088#comment-17047088 ] Xiang Zhang commented on KAFKA-9592: [~guozhang] Is KAFKA-5606 already fixed or not ? I see that

[jira] [Commented] (KAFKA-9622) Improve tests to detect post-processing failures in Jetty request handling.

[ https://issues.apache.org/jira/browse/KAFKA-9622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17047004#comment-17047004 ] Ismael Juma commented on KAFKA-9622: [~kkonstantine] Since Connect is the main user of Jetty in

[jira] [Updated] (KAFKA-9622) Improve tests to detect post-processing failures in Jetty request handling.

[ https://issues.apache.org/jira/browse/KAFKA-9622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rigel Bezerra de Melo updated KAFKA-9622: - Component/s: (was: streams) > Improve tests to detect post-processing

[jira] [Created] (KAFKA-9622) Improve tests to detect post-processing failures in Jetty request handling.

Rigel Bezerra de Melo created KAFKA-9622: Summary: Improve tests to detect post-processing failures in Jetty request handling. Key: KAFKA-9622 URL: https://issues.apache.org/jira/browse/KAFKA-9622

[jira] [Updated] (KAFKA-9621) AdminClient listOffsets operation does not respect retries and backoff

[ https://issues.apache.org/jira/browse/KAFKA-9621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sanjana Kaundinya updated KAFKA-9621: - Description: Similar to https://issues.apache.org/jira/browse/KAFKA-9047, currently the

[jira] [Updated] (KAFKA-9621) AdminClient listOffsets operation does not respect retries and backoff

[ https://issues.apache.org/jira/browse/KAFKA-9621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sanjana Kaundinya updated KAFKA-9621: - Description: Similar to https://issues.apache.org/jira/browse/KAFKA-9047, currently the

[jira] [Created] (KAFKA-9621) AdminClient listOffsets operation does not respect retries and backoff

Sanjana Kaundinya created KAFKA-9621: Summary: AdminClient listOffsets operation does not respect retries and backoff Key: KAFKA-9621 URL: https://issues.apache.org/jira/browse/KAFKA-9621

[jira] [Updated] (KAFKA-9533) ValueTransform forwards `null` values

[ https://issues.apache.org/jira/browse/KAFKA-9533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9533: Fix Version/s: (was: 2.4.1) (was: 2.3.2) (was:

[jira] [Resolved] (KAFKA-7932) Streams needs to handle new Producer exceptions

[ https://issues.apache.org/jira/browse/KAFKA-7932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-7932. - Resolution: Duplicate Subsumed by https://issues.apache.org/jira/browse/KAFKA-9274 > Streams

[jira] [Updated] (KAFKA-9533) ValueTransform forwards `null` values

[ https://issues.apache.org/jira/browse/KAFKA-9533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Arthur updated KAFKA-9533: Fix Version/s: (was: 2.5.0) > ValueTransform forwards `null` values >

[jira] [Updated] (KAFKA-7932) Streams needs to handle new Producer exceptions

[ https://issues.apache.org/jira/browse/KAFKA-7932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-7932: Fix Version/s: (was: 2.5.0) > Streams needs to handle new Producer exceptions >

[jira] [Commented] (KAFKA-9620) Task revocation failure could introduce remaining unclean tasks

[ https://issues.apache.org/jira/browse/KAFKA-9620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17046995#comment-17046995 ] Guozhang Wang commented on KAFKA-9620: -- I think there are two issues we've observed that needs

[jira] [Resolved] (KAFKA-9091) KIP-538: Add a metric tracking the number of open connections with a given SSL cipher type

[ https://issues.apache.org/jira/browse/KAFKA-9091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Arthur resolved KAFKA-9091. - Resolution: Fixed > KIP-538: Add a metric tracking the number of open connections with a given

[jira] [Updated] (KAFKA-9333) Shim `core` module that targets default scala version (KIP-531)

[ https://issues.apache.org/jira/browse/KAFKA-9333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Arthur updated KAFKA-9333: Fix Version/s: (was: 2.5.0) 2.6.0 > Shim `core` module that targets default

[jira] [Updated] (KAFKA-9096) Validate config inter-dependencies for KafkaConfig only after dynamic configs are loaded

[ https://issues.apache.org/jira/browse/KAFKA-9096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Arthur updated KAFKA-9096: Fix Version/s: (was: 2.5.0) 2.6.0 > Validate config inter-dependencies for

[jira] [Updated] (KAFKA-9076) MirrorMaker 2.0 automated consumer offset sync

[ https://issues.apache.org/jira/browse/KAFKA-9076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Arthur updated KAFKA-9076: Fix Version/s: (was: 2.5.0) 2.6.0 > MirrorMaker 2.0 automated consumer

[jira] [Updated] (KAFKA-8597) Give access to the Dead Letter Queue APIs to Kafka Connect Developers

[ https://issues.apache.org/jira/browse/KAFKA-8597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Arthur updated KAFKA-8597: Fix Version/s: (was: 2.5.0) 2.6.0 > Give access to the Dead Letter Queue

[jira] [Updated] (KAFKA-5722) Refactor ConfigCommand to use the AdminClient

[ https://issues.apache.org/jira/browse/KAFKA-5722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Arthur updated KAFKA-5722: Fix Version/s: (was: 2.5.0) 2.6.0 > Refactor ConfigCommand to use the

[jira] [Updated] (KAFKA-9145) AbstractCoordinator should respect retry backoff between rebalances

[ https://issues.apache.org/jira/browse/KAFKA-9145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Arthur updated KAFKA-9145: Fix Version/s: (was: 2.5.0) 2.6.0 > AbstractCoordinator should respect

[jira] [Updated] (KAFKA-9397) Deprecate Direct Zookeeper access in Kafka Administrative Tools

[ https://issues.apache.org/jira/browse/KAFKA-9397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Arthur updated KAFKA-9397: Fix Version/s: (was: 2.5.0) 2.6.0 > Deprecate Direct Zookeeper access in

[jira] [Updated] (KAFKA-9520) Deprecate ZooKeeper access for kafka-reassign-partitions.sh

[ https://issues.apache.org/jira/browse/KAFKA-9520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Arthur updated KAFKA-9520: Fix Version/s: (was: 2.5.0) 2.6.0 > Deprecate ZooKeeper access for

[jira] [Commented] (KAFKA-9620) Task revocation failure could introduce remaining unclean tasks

[ https://issues.apache.org/jira/browse/KAFKA-9620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17046964#comment-17046964 ] ASF GitHub Bot commented on KAFKA-9620: --- abbccdda commented on pull request #8187: KAFKA-9620:

[jira] [Created] (KAFKA-9620) Task revocation failure could introduce remaining unclean tasks

Boyang Chen created KAFKA-9620: -- Summary: Task revocation failure could introduce remaining unclean tasks Key: KAFKA-9620 URL: https://issues.apache.org/jira/browse/KAFKA-9620 Project: Kafka

[jira] [Commented] (KAFKA-8247) Duplicate error handling in kafka-server-start.sh and actual Kafka class

[ https://issues.apache.org/jira/browse/KAFKA-8247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17046960#comment-17046960 ] Sönke Liebau commented on KAFKA-8247: - ping [~hachikuji] > Duplicate error handling in

[jira] [Commented] (KAFKA-9618) Failed state store deletion could lead to task file not found

[ https://issues.apache.org/jira/browse/KAFKA-9618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17046915#comment-17046915 ] ASF GitHub Bot commented on KAFKA-9618: --- abbccdda commented on pull request #8186: KAFKA-9618:

[jira] [Created] (KAFKA-9619) Receiving duplicates when application is configured for exactly once

Cristian Manoliu created KAFKA-9619: --- Summary: Receiving duplicates when application is configured for exactly once Key: KAFKA-9619 URL: https://issues.apache.org/jira/browse/KAFKA-9619 Project:

[jira] [Updated] (KAFKA-9619) Receiving duplicates when application is configured for exactly once

[ https://issues.apache.org/jira/browse/KAFKA-9619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Cristian Manoliu updated KAFKA-9619: Attachment: log > Receiving duplicates when application is configured for exactly once >

[jira] [Created] (KAFKA-9618) Failed state store deletion could lead to task file not found

Boyang Chen created KAFKA-9618: -- Summary: Failed state store deletion could lead to task file not found Key: KAFKA-9618 URL: https://issues.apache.org/jira/browse/KAFKA-9618 Project: Kafka

[jira] [Commented] (KAFKA-5041) Kafka TestKit library

[ https://issues.apache.org/jira/browse/KAFKA-5041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17046820#comment-17046820 ] John Roesler commented on KAFKA-5041: - Hi all, you may also wish to be aware of this recent thread:

[jira] [Commented] (KAFKA-9611) KGroupedTable.aggregate(...) emits incorrect values

[ https://issues.apache.org/jira/browse/KAFKA-9611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17046798#comment-17046798 ] John Roesler commented on KAFKA-9611: - Hi [~neilgreen] , It seems like classifying this as a bug is

[jira] [Comment Edited] (KAFKA-9611) KGroupedTable.aggregate(...) emits incorrect values

[ https://issues.apache.org/jira/browse/KAFKA-9611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17046678#comment-17046678 ] Neil Green edited comment on KAFKA-9611 at 2/27/20 4:30 PM: I think it is a

[jira] [Commented] (KAFKA-9603) Number of open files keeps increasing in Streams application

[ https://issues.apache.org/jira/browse/KAFKA-9603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17046775#comment-17046775 ] Bruno Iljazovic commented on KAFKA-9603: Number of open files grows at constant speed from low

[jira] [Created] (KAFKA-9617) Replica Fetcher can mark partition as failed when max.message.bytes is changed

Stanislav Kozlovski created KAFKA-9617: -- Summary: Replica Fetcher can mark partition as failed when max.message.bytes is changed Key: KAFKA-9617 URL: https://issues.apache.org/jira/browse/KAFKA-9617

[jira] [Comment Edited] (KAFKA-9611) KGroupedTable.aggregate(...) emits incorrect values

[ https://issues.apache.org/jira/browse/KAFKA-9611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17046678#comment-17046678 ] Neil Green edited comment on KAFKA-9611 at 2/27/20 2:40 PM: I think it is a

[jira] [Commented] (KAFKA-9118) LogDirFailureHandler shouldn't use Zookeeper

[ https://issues.apache.org/jira/browse/KAFKA-9118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17046681#comment-17046681 ] Viktor Somogyi-Vass commented on KAFKA-9118: [~bchen225242] yes, that's correct. I've rebased

[jira] [Commented] (KAFKA-9611) KGroupedTable.aggregate(...) emits incorrect values

[ https://issues.apache.org/jira/browse/KAFKA-9611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17046678#comment-17046678 ] Neil Green commented on KAFKA-9611: --- I think it is a bug. One received message results in two messages

[jira] [Assigned] (KAFKA-4090) JVM runs into OOM if (Java) client uses a SSL port without setting the security protocol

[ https://issues.apache.org/jira/browse/KAFKA-4090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexandre Dupriez reassigned KAFKA-4090: Assignee: (was: Alexandre Dupriez) > JVM runs into OOM if (Java) client uses

[jira] [Assigned] (KAFKA-4090) JVM runs into OOM if (Java) client uses a SSL port without setting the security protocol

[ https://issues.apache.org/jira/browse/KAFKA-4090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexandre Dupriez reassigned KAFKA-4090: Assignee: Alexandre Dupriez > JVM runs into OOM if (Java) client uses a SSL port

[jira] [Commented] (KAFKA-9611) KGroupedTable.aggregate(...) emits incorrect values

[ https://issues.apache.org/jira/browse/KAFKA-9611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17046648#comment-17046648 ] Bruno Cadonna commented on KAFKA-9611: -- [~mjsax] OK, I see. That would explain the observation.

[jira] [Commented] (KAFKA-9343) Make Kafka shell runnable on z/OS

[ https://issues.apache.org/jira/browse/KAFKA-9343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17046643#comment-17046643 ] Brandon Wittwer commented on KAFKA-9343: Is this a bug fix or a feature request?  2.4.1 is a bug

[jira] [Updated] (KAFKA-9604) Падение кластера

[ https://issues.apache.org/jira/browse/KAFKA-9604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maksim Larionov updated KAFKA-9604: --- Description: Good day! A disk space overflow occurred on one of the servers in the cluster.

[jira] [Commented] (KAFKA-9604) Падение кластера

[ https://issues.apache.org/jira/browse/KAFKA-9604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17046534#comment-17046534 ] Maksim Larionov commented on KAFKA-9604: Thank you for your answer! I changed the language of

[jira] [Updated] (KAFKA-9604) Падение кластера

[ https://issues.apache.org/jira/browse/KAFKA-9604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maksim Larionov updated KAFKA-9604: --- Description: Good day! A disk space overflow occurred on one of the servers in the cluster.

[jira] [Commented] (KAFKA-9613) orruptRecordException: Found record size 0 smaller than minimum record overhead

[ https://issues.apache.org/jira/browse/KAFKA-9613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17046407#comment-17046407 ] Sönke Liebau commented on KAFKA-9613: - Hi [~khandelwal.amit] can you please provide some additional

[jira] [Resolved] (KAFKA-9609) Memory Leak in Kafka Producer

[ https://issues.apache.org/jira/browse/KAFKA-9609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sönke Liebau resolved KAFKA-9609. - Assignee: Sönke Liebau Resolution: Not A Bug As discussed in the comments I do not believe

[jira] [Assigned] (KAFKA-9561) Update task input partitions when topic metadata changes

[ https://issues.apache.org/jira/browse/KAFKA-9561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stepanenko Vyacheslav reassigned KAFKA-9561: Assignee: Stepanenko Vyacheslav > Update task input partitions when topic