[jira] [Created] (KAFKA-8253) Unrecoverable state when a broker's INPUT access is blocked (Zombie broker)

Gowtham Gutha created KAFKA-8253: Summary: Unrecoverable state when a broker's INPUT access is blocked (Zombie broker) Key: KAFKA-8253 URL: https://issues.apache.org/jira/browse/KAFKA-8253 Project: Ka

[jira] [Updated] (KAFKA-8253) Unrecoverable state when a broker's INPUT access is blocked (Zombie broker)

[ https://issues.apache.org/jira/browse/KAFKA-8253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gowtham Gutha updated KAFKA-8253: - Description: I carried out a test as mentioned in my SO question [https://stackoverflow.com/ques

[jira] [Resolved] (KAFKA-8252) topic catalog.offer-updated.1 has an unexpected message

[ https://issues.apache.org/jira/browse/KAFKA-8252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zan fu resolved KAFKA-8252. --- Resolution: Not A Bug > topic catalog.offer-updated.1 has an unexpected message > ---

[jira] [Commented] (KAFKA-8248) Producer may fail IllegalStateException

[ https://issues.apache.org/jira/browse/KAFKA-8248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16820743#comment-16820743 ] Ayusman Dikshit commented on KAFKA-8248: Does this issue ONLY apply to 2.0.0 or l

[jira] [Created] (KAFKA-8252) topic catalog.offer-updated.1 has an unexpected message

zan fu created KAFKA-8252: - Summary: topic catalog.offer-updated.1 has an unexpected message Key: KAFKA-8252 URL: https://issues.apache.org/jira/browse/KAFKA-8252 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-8246) refactor topic/group instance id validation condition

[ https://issues.apache.org/jira/browse/KAFKA-8246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16820708#comment-16820708 ] Boyang Chen commented on KAFKA-8246: Interesting, thanks for the info! [~sliebau] Cc

[jira] [Commented] (KAFKA-8153) Streaming application with state stores takes up to 1 hour to restart

[ https://issues.apache.org/jira/browse/KAFKA-8153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16820680#comment-16820680 ] Matthias J. Sax commented on KAFKA-8153: [~mmelsen] Any updates on this? I am won

[jira] [Commented] (KAFKA-8155) Update Streams system tests for 2.2.0 and 2.1.1 releases

[ https://issues.apache.org/jira/browse/KAFKA-8155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16820671#comment-16820671 ] ASF GitHub Bot commented on KAFKA-8155: --- mjsax commented on pull request #6597: KAF

[jira] [Commented] (KAFKA-8155) Update Streams system tests for 2.2.0 and 2.1.1 releases

[ https://issues.apache.org/jira/browse/KAFKA-8155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16820666#comment-16820666 ] ASF GitHub Bot commented on KAFKA-8155: --- mjsax commented on pull request #6596: KA

[jira] [Created] (KAFKA-8251) Consider different logging for purgeData

Matthias J. Sax created KAFKA-8251: -- Summary: Consider different logging for purgeData Key: KAFKA-8251 URL: https://issues.apache.org/jira/browse/KAFKA-8251 Project: Kafka Issue Type: Improv

[jira] [Commented] (KAFKA-4212) Add a key-value store that is a TTL persistent cache

[ https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16820644#comment-16820644 ] Chris Toomey commented on KAFKA-4212: - Our use case is we're using RocksDB as a key/v

[jira] [Created] (KAFKA-8250) Flaky Test DelegationTokenEndToEndAuthorizationTest#testProduceConsumeViaAssign

Matthias J. Sax created KAFKA-8250: -- Summary: Flaky Test DelegationTokenEndToEndAuthorizationTest#testProduceConsumeViaAssign Key: KAFKA-8250 URL: https://issues.apache.org/jira/browse/KAFKA-8250 Pro

[jira] [Commented] (KAFKA-7647) Flaky test LogCleanerParameterizedIntegrationTest.testCleansCombinedCompactAndDeleteTopic

[ https://issues.apache.org/jira/browse/KAFKA-7647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16820612#comment-16820612 ] Matthias J. Sax commented on KAFKA-7647: https://builds.apache.org/blue/organizat

[jira] [Commented] (KAFKA-8248) Producer may fail IllegalStateException

[ https://issues.apache.org/jira/browse/KAFKA-8248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16820597#comment-16820597 ] Jason Gustafson commented on KAFKA-8248: Looking at the code, I think the problem

[jira] [Comment Edited] (KAFKA-8185) Controller becomes stale and not able to failover the leadership for the partitions

[ https://issues.apache.org/jira/browse/KAFKA-8185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16820573#comment-16820573 ] Dhruvil Shah edited comment on KAFKA-8185 at 4/17/19 11:45 PM:

[jira] [Comment Edited] (KAFKA-8185) Controller becomes stale and not able to failover the leadership for the partitions

[ https://issues.apache.org/jira/browse/KAFKA-8185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16820573#comment-16820573 ] Dhruvil Shah edited comment on KAFKA-8185 at 4/17/19 11:42 PM:

[jira] [Commented] (KAFKA-7652) Kafka Streams Session store performance degradation from 0.10.2.2 to 0.11.0.0

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

[jira] [Created] (KAFKA-8249) partition reassignment may never finish if topic deletion completes first

xiongqi wu created KAFKA-8249: - Summary: partition reassignment may never finish if topic deletion completes first Key: KAFKA-8249 URL: https://issues.apache.org/jira/browse/KAFKA-8249 Project: Kafka

[jira] [Resolved] (KAFKA-8185) Controller becomes stale and not able to failover the leadership for the partitions

[ https://issues.apache.org/jira/browse/KAFKA-8185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dhruvil Shah resolved KAFKA-8185. - Resolution: Not A Problem This is not a typically expected scenario and would only happen when th

[jira] [Updated] (KAFKA-8248) Producer may fail IllegalStateException

[ https://issues.apache.org/jira/browse/KAFKA-8248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8248: --- Description: In a Kafka Streams application, we observed the following log from the producer:

[jira] [Created] (KAFKA-8248) Producer may fail IllegalStateException

Matthias J. Sax created KAFKA-8248: -- Summary: Producer may fail IllegalStateException Key: KAFKA-8248 URL: https://issues.apache.org/jira/browse/KAFKA-8248 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-5998) /.checkpoint.tmp Not found exception

[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16820523#comment-16820523 ] Patrik Kleindl commented on KAFKA-5998: --- [~guozhang] Could you please share the dir

[jira] [Commented] (KAFKA-6520) When a Kafka Stream can't communicate with the server, it's Status stays RUNNING

[ https://issues.apache.org/jira/browse/KAFKA-6520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16820488#comment-16820488 ] ASF GitHub Bot commented on KAFKA-6520: --- ConcurrencyPractitioner commented on pull

[jira] [Commented] (KAFKA-8147) Add changelog topic configuration to KTable suppress

[ https://issues.apache.org/jira/browse/KAFKA-8147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16820474#comment-16820474 ] ASF GitHub Bot commented on KAFKA-8147: --- mjduijn commented on pull request #6593: [

[jira] [Resolved] (KAFKA-8241) Dynamic update of keystore fails on listener without truststore

[ https://issues.apache.org/jira/browse/KAFKA-8241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-8241. --- Resolution: Fixed Reviewer: Manikumar Fix Version/s: 2.1.2 > Dynamic update o

[jira] [Updated] (KAFKA-7965) Flaky Test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

[ https://issues.apache.org/jira/browse/KAFKA-7965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-7965: --- Fix Version/s: (was: 2.2.1) > Flaky Test > ConsumerBounceTest#testRollingBrokerRestartsW

[jira] [Resolved] (KAFKA-7965) Flaky Test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

[ https://issues.apache.org/jira/browse/KAFKA-7965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7965. Resolution: Fixed > Flaky Test > ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMa

[jira] [Commented] (KAFKA-7965) Flaky Test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

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

[jira] [Assigned] (KAFKA-8155) Update Streams system tests for 2.2.0 and 2.1.1 releases

[ https://issues.apache.org/jira/browse/KAFKA-8155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-8155: -- Assignee: Matthias J. Sax (was: John Roesler) > Update Streams system tests for 2.2.0

[jira] [Commented] (KAFKA-8025) Flaky Test RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsAdapterTest#shouldForwardAllDbOptionsCalls

[ https://issues.apache.org/jira/browse/KAFKA-8025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16820402#comment-16820402 ] ASF GitHub Bot commented on KAFKA-8025: --- bbejeck commented on pull request #6370: K

[jira] [Updated] (KAFKA-8231) Expansion of ConnectClusterState interface

[ https://issues.apache.org/jira/browse/KAFKA-8231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-8231: - Fix Version/s: (was: 2.3.0) > Expansion of ConnectClusterState interface > --

[jira] [Commented] (KAFKA-8215) Limit memory usage of RocksDB

[ https://issues.apache.org/jira/browse/KAFKA-8215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16820353#comment-16820353 ] ASF GitHub Bot commented on KAFKA-8215: --- ableegoldman commented on pull request #65

[jira] [Commented] (KAFKA-8241) Dynamic update of keystore fails on listener without truststore

[ https://issues.apache.org/jira/browse/KAFKA-8241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16820322#comment-16820322 ] ASF GitHub Bot commented on KAFKA-8241: --- rajinisivaram commented on pull request #6

[jira] [Updated] (KAFKA-3539) KafkaProducer.send() may block even though it returns the Future

[ https://issues.apache.org/jira/browse/KAFKA-3539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Richard Yu updated KAFKA-3539: -- Labels: needs-discussion needs-kip (was: ) > KafkaProducer.send() may block even though it returns the

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

Sönke Liebau created KAFKA-8247: --- Summary: Duplicate error handling in kafka-server-start.sh and actual Kafka class Key: KAFKA-8247 URL: https://issues.apache.org/jira/browse/KAFKA-8247 Project: Kafka

[jira] [Commented] (KAFKA-7937) Flaky Test ResetConsumerGroupOffsetTest.testResetOffsetsNotExistingGroup

[ https://issues.apache.org/jira/browse/KAFKA-7937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16820256#comment-16820256 ] Matthias J. Sax commented on KAFKA-7937: [https://builds.apache.org/blue/organiza

[jira] [Commented] (KAFKA-8041) Flaky Test LogDirFailureTest#testIOExceptionDuringLogRoll

[ https://issues.apache.org/jira/browse/KAFKA-8041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16820255#comment-16820255 ] Matthias J. Sax commented on KAFKA-8041: One more:  [https://builds.apache.org/bl

[jira] [Commented] (KAFKA-7965) Flaky Test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

[ https://issues.apache.org/jira/browse/KAFKA-7965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16820248#comment-16820248 ] Matthias J. Sax commented on KAFKA-7965: [https://builds.apache.org/job/kafka-pr-

[jira] [Commented] (KAFKA-6455) Improve timestamp propagation at DSL level

[ https://issues.apache.org/jira/browse/KAFKA-6455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16820247#comment-16820247 ] ASF GitHub Bot commented on KAFKA-6455: --- mjsax commented on pull request #6565: KAF

[jira] [Assigned] (KAFKA-8187) State store record loss across multiple reassignments when using standby tasks

[ https://issues.apache.org/jira/browse/KAFKA-8187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-8187: -- Assignee: Matthias J. Sax (was: Bill Bejeck) > State store record loss across multipl

[jira] [Commented] (KAFKA-6951) Implement offset expiration semantics for unsubscribed topics

[ https://issues.apache.org/jira/browse/KAFKA-6951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16820132#comment-16820132 ] Emmanuel Brard commented on KAFKA-6951: --- [~wushujames] it's not implemented yet:

[jira] [Assigned] (KAFKA-5609) Connect log4j should log to file by default

[ https://issues.apache.org/jira/browse/KAFKA-5609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kaufman Ng reassigned KAFKA-5609: - Assignee: Kaufman Ng > Connect log4j should log to file by default > ---

[jira] [Commented] (KAFKA-5998) /.checkpoint.tmp Not found exception

[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16819913#comment-16819913 ] Rabih Hallage commented on KAFKA-5998: -- Hello Guys, I'm experiencing the same issue

[jira] [Commented] (KAFKA-8246) refactor topic/group instance id validation condition

[ https://issues.apache.org/jira/browse/KAFKA-8246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16819899#comment-16819899 ] Sönke Liebau commented on KAFKA-8246: - I believe that used to be a regular expression

[jira] [Commented] (KAFKA-8110) Flaky Test DescribeConsumerGroupTest#testDescribeMembersWithConsumersWithoutAssignedPartitions

[ https://issues.apache.org/jira/browse/KAFKA-8110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16819784#comment-16819784 ] Matthias J. Sax commented on KAFKA-8110: Failed again:  [https://builds.apache.or

[jira] [Commented] (KAFKA-7965) Flaky Test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

[ https://issues.apache.org/jira/browse/KAFKA-7965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16819781#comment-16819781 ] Matthias J. Sax commented on KAFKA-7965: [https://builds.apache.org/job/kafka-pr-