[jira] [Updated] (KAFKA-8741) We should optimize the use of JMX web interface

[ https://issues.apache.org/jira/browse/KAFKA-8741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] maohong updated KAFKA-8741: --- Affects Version/s: (was: 2.2.1) (was: 2.3.0) (was: 2

[jira] [Commented] (KAFKA-7548) KafkaConsumer should not throw away already fetched data for paused partitions.

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

[jira] [Resolved] (KAFKA-7548) KafkaConsumer should not throw away already fetched data for paused partitions.

[ https://issues.apache.org/jira/browse/KAFKA-7548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7548. Resolution: Fixed Fix Version/s: 2.4.0 > KafkaConsumer should not throw away already

[jira] [Commented] (KAFKA-7548) KafkaConsumer should not throw away already fetched data for paused partitions.

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

[jira] [Commented] (KAFKA-8745) DumpLogSegments doesn't show keys, when the message is null

[ https://issues.apache.org/jira/browse/KAFKA-8745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16898440#comment-16898440 ] James Cheng commented on KAFKA-8745: [~guozhang]: This is ready for review. The instr

[jira] [Updated] (KAFKA-8745) DumpLogSegments doesn't show keys, when the message is null

[ https://issues.apache.org/jira/browse/KAFKA-8745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] James Cheng updated KAFKA-8745: --- Flags: (was: Patch) > DumpLogSegments doesn't show keys, when the message is null > ---

[jira] [Updated] (KAFKA-8745) DumpLogSegments doesn't show keys, when the message is null

[ https://issues.apache.org/jira/browse/KAFKA-8745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] James Cheng updated KAFKA-8745: --- Flags: Patch > DumpLogSegments doesn't show keys, when the message is null >

[jira] [Commented] (KAFKA-8745) DumpLogSegments doesn't show keys, when the message is null

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

[jira] [Created] (KAFKA-8745) DumpLogSegments doesn't show keys, when the message is null

James Cheng created KAFKA-8745: -- Summary: DumpLogSegments doesn't show keys, when the message is null Key: KAFKA-8745 URL: https://issues.apache.org/jira/browse/KAFKA-8745 Project: Kafka Issue

[jira] [Assigned] (KAFKA-8745) DumpLogSegments doesn't show keys, when the message is null

[ https://issues.apache.org/jira/browse/KAFKA-8745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] James Cheng reassigned KAFKA-8745: -- Assignee: James Cheng > DumpLogSegments doesn't show keys, when the message is null >

[jira] [Commented] (KAFKA-7911) Add Timezone Support for Windowed Aggregations

[ https://issues.apache.org/jira/browse/KAFKA-7911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16898413#comment-16898413 ] Harshil Shah commented on KAFKA-7911: - Hey folks,   We stumbled upon similar issue,

[jira] [Created] (KAFKA-8744) Add Support to Scala API for KIP-307

Bill Bejeck created KAFKA-8744: -- Summary: Add Support to Scala API for KIP-307 Key: KAFKA-8744 URL: https://issues.apache.org/jira/browse/KAFKA-8744 Project: Kafka Issue Type: Task Com

[jira] [Commented] (KAFKA-8601) Producer Improvement: Sticky Partitioner

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

[jira] [Commented] (KAFKA-8589) Flakey test ResetConsumerGroupOffsetTest#testResetOffsetsExistingTopic

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

[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=16898347#comment-16898347 ] Matthias J. Sax commented on KAFKA-8041: [https://builds.apache.org/job/kafka-pr-

[jira] [Commented] (KAFKA-8677) Flakey test GroupEndToEndAuthorizationTest#testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl

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

[jira] [Commented] (KAFKA-8736) Performance: ThreadCache uses size() for empty cache check

[ https://issues.apache.org/jira/browse/KAFKA-8736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16898285#comment-16898285 ] Matthew Jarvie commented on KAFKA-8736: --- Sure! Let me try to find some time in the

[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=16898283#comment-16898283 ] Matthias J. Sax commented on KAFKA-7937: [https://builds.apache.org/job/kafka-pr-

[jira] [Updated] (KAFKA-8743) Flaky Test RepartitionWithMergeOptimizingIntegrationTest#shouldSendCorrectRecords_OPTIMIZED

[ https://issues.apache.org/jira/browse/KAFKA-8743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8743: --- Labels: flaky-test (was: ) > Flaky Test > RepartitionWithMergeOptimizingIntegrationTest#sho

[jira] [Updated] (KAFKA-8743) Flaky Test RepartitionWithMergeOptimizingIntegrationTest#shouldSendCorrectRecords_OPTIMIZED

[ https://issues.apache.org/jira/browse/KAFKA-8743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8743: --- Description: [https://builds.apache.org/job/kafka-pr-jdk11-scala2.12/6662/testReport/junit/or

[jira] [Created] (KAFKA-8743) Flaky Test RepartitionWithMergeOptimizingIntegrationTest#shouldSendCorrectRecords_OPTIMIZED

Matthias J. Sax created KAFKA-8743: -- Summary: Flaky Test RepartitionWithMergeOptimizingIntegrationTest#shouldSendCorrectRecords_OPTIMIZED Key: KAFKA-8743 URL: https://issues.apache.org/jira/browse/KAFKA-8743

[jira] [Created] (KAFKA-8742) Flaky Test RepartitionWithMergeOptimizingIntegrationTest#shouldSendCorrectResults_NO_OPTIMIZATION

Matthias J. Sax created KAFKA-8742: -- Summary: Flaky Test RepartitionWithMergeOptimizingIntegrationTest#shouldSendCorrectResults_NO_OPTIMIZATION Key: KAFKA-8742 URL: https://issues.apache.org/jira/browse/KAFKA-874

[jira] [Updated] (KAFKA-6461) TableTableJoinIntegrationTest is unstable if caching is enabled

[ https://issues.apache.org/jira/browse/KAFKA-6461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6461: --- Labels: flaky-test (was: ) > TableTableJoinIntegrationTest is unstable if caching is enabled

[jira] [Reopened] (KAFKA-6461) TableTableJoinIntegrationTest is unstable if caching is enabled

[ https://issues.apache.org/jira/browse/KAFKA-6461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-6461: Assignee: (was: Ted Yu) Failed again in `trunk`:  [https://builds.apache.org/job/kafk

[jira] [Commented] (KAFKA-8059) Flaky Test DynamicConnectionQuotaTest #testDynamicConnectionQuota

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

[jira] [Commented] (KAFKA-8083) Flaky Test DelegationTokenRequestsTest#testDelegationTokenRequests

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

[jira] [Commented] (KAFKA-8672) RebalanceSourceConnectorsIntegrationTest#testReconfigConnector

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

[jira] [Commented] (KAFKA-8677) Flakey test GroupEndToEndAuthorizationTest#testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl

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

[jira] [Commented] (KAFKA-8555) Flaky test ExampleConnectIntegrationTest#testSourceConnector

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

[jira] [Commented] (KAFKA-8672) RebalanceSourceConnectorsIntegrationTest#testReconfigConnector

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

[jira] [Commented] (KAFKA-8456) Flaky Test StoreUpgradeIntegrationTest#shouldMigratePersistentWindowStoreToTimestampedWindowStoreUsingPapi

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

[jira] [Commented] (KAFKA-5632) Message headers not supported by Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-5632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16898251#comment-16898251 ] Matthias J. Sax commented on KAFKA-5632: Different people created different ticke

[jira] [Commented] (KAFKA-4125) Provide low-level Processor API meta data in DSL layer

[ https://issues.apache.org/jira/browse/KAFKA-4125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16898249#comment-16898249 ] Matthias J. Sax commented on KAFKA-4125: We can, but because all versions are aff

[jira] [Commented] (KAFKA-8731) InMemorySessionStore throws NullPointerException on startup

[ https://issues.apache.org/jira/browse/KAFKA-8731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16898199#comment-16898199 ] Guozhang Wang commented on KAFKA-8731: -- Let's see how many blockers we have accumula

[jira] [Updated] (KAFKA-8741) We should optimize the use of JMX web interface

[ https://issues.apache.org/jira/browse/KAFKA-8741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] maohong updated KAFKA-8741: --- Description: # Since mx4j-tools.jar is not packaged into the final released tgz file by default, we can't mo

[jira] [Commented] (KAFKA-8465) Make sure that the copy of the same topic is evenly distributed across a broker's disk.

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

[jira] [Created] (KAFKA-8741) We should add mx4j-tools.jar into dependencies

maohong created KAFKA-8741: -- Summary: We should add mx4j-tools.jar into dependencies Key: KAFKA-8741 URL: https://issues.apache.org/jira/browse/KAFKA-8741 Project: Kafka Issue Type: Wish C

[jira] [Commented] (KAFKA-7500) MirrorMaker 2.0 (KIP-382)

[ https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16898120#comment-16898120 ] jacob shao commented on KAFKA-7500: --- Hey, I use kubernettes to spin up 2 kafka cluster

[jira] [Updated] (KAFKA-8602) StreamThread Dies Because Restore Consumer is not Subscribed to Any Topic

[ https://issues.apache.org/jira/browse/KAFKA-8602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-8602: - Affects Version/s: 1.0.3 1.0.0 1.0.1

[jira] [Commented] (KAFKA-8602) StreamThread Dies Because Restore Consumer is not Subscribed to Any Topic

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

[jira] [Commented] (KAFKA-8602) StreamThread Dies Because Restore Consumer is not Subscribed to Any Topic

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

[jira] [Commented] (KAFKA-5632) Message headers not supported by Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-5632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16897938#comment-16897938 ] Antony Stubbs commented on KAFKA-5632: -- [~mjsax] [~guozhang] I think this should be

[jira] [Commented] (KAFKA-4125) Provide low-level Processor API meta data in DSL layer

[ https://issues.apache.org/jira/browse/KAFKA-4125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16897937#comment-16897937 ] Antony Stubbs commented on KAFKA-4125: -- Can we add 2.3 as an affected version? > Pr

[jira] [Commented] (KAFKA-8602) StreamThread Dies Because Restore Consumer is not Subscribed to Any Topic

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

[jira] [Commented] (KAFKA-8602) StreamThread Dies Because Restore Consumer is not Subscribed to Any Topic

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

[jira] [Commented] (KAFKA-8602) StreamThread Dies Because Restore Consumer is not Subscribed to Any Topic

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

[jira] [Commented] (KAFKA-8740) Threads causing circular deadlock

[ https://issues.apache.org/jira/browse/KAFKA-8740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16897864#comment-16897864 ] Manikumar commented on KAFKA-8740: -- Some of the deadlock issues are fixed in newer versi

[jira] [Updated] (KAFKA-8740) Threads causing circular deadlock

[ https://issues.apache.org/jira/browse/KAFKA-8740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sukumar Enuguri updated KAFKA-8740: --- Attachment: threaddumps-31Jul2019.tar > Threads causing circular deadlock >

[jira] [Updated] (KAFKA-8740) Threads causing circular deadlock

[ https://issues.apache.org/jira/browse/KAFKA-8740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sukumar Enuguri updated KAFKA-8740: --- Attachment: threaddumps-29Jul2019.tar > Threads causing circular deadlock >

[jira] [Created] (KAFKA-8740) Threads causing circular deadlock

Sukumar Enuguri created KAFKA-8740: -- Summary: Threads causing circular deadlock Key: KAFKA-8740 URL: https://issues.apache.org/jira/browse/KAFKA-8740 Project: Kafka Issue Type: Bug