[jira] [Comment Edited] (KAFKA-9152) Improve Sensor Retrieval

[ https://issues.apache.org/jira/browse/KAFKA-9152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17012572#comment-17012572 ] highluck edited comment on KAFKA-9152 at 1/10/20 8:40 AM: -- [~cad

[jira] [Commented] (KAFKA-9152) Improve Sensor Retrieval

[ https://issues.apache.org/jira/browse/KAFKA-9152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17012572#comment-17012572 ] highluck commented on KAFKA-9152: - [~cadonna] [https://github.com/apache/kafka/pull/7914

[jira] [Updated] (KAFKA-7519) Transactional Ids Left in Pending State by TransactionStateManager During Transactional Id Expiration Are Unusable

[ https://issues.apache.org/jira/browse/KAFKA-7519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alper Kanat updated KAFKA-7519: --- Attachment: image-2020-01-10-12-37-28-804.png > Transactional Ids Left in Pending State by Transactio

[jira] [Commented] (KAFKA-7519) Transactional Ids Left in Pending State by TransactionStateManager During Transactional Id Expiration Are Unusable

[ https://issues.apache.org/jira/browse/KAFKA-7519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17012625#comment-17012625 ] Alper Kanat commented on KAFKA-7519: I just had the exact error in Kafka 2.2.0 – any

[jira] [Commented] (KAFKA-8764) LogCleanerManager endless loop while compacting/cleaning segments

[ https://issues.apache.org/jira/browse/KAFKA-8764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17012667#comment-17012667 ] Seva Feldman commented on KAFKA-8764: - Hi, We have the exact same issue with __consu

[jira] [Commented] (KAFKA-2758) Improve Offset Commit Behavior

[ https://issues.apache.org/jira/browse/KAFKA-2758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17012672#comment-17012672 ] highluck commented on KAFKA-2758: - [~guozhang] Is this issue still open   > Improve Of

[jira] [Comment Edited] (KAFKA-2758) Improve Offset Commit Behavior

[ https://issues.apache.org/jira/browse/KAFKA-2758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17012672#comment-17012672 ] highluck edited comment on KAFKA-2758 at 1/10/20 10:16 AM: --- [~g

[jira] [Updated] (KAFKA-8764) LogCleanerManager endless loop while compacting/cleaning segments

[ https://issues.apache.org/jira/browse/KAFKA-8764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tomislav Rajakovic updated KAFKA-8764: -- Affects Version/s: 2.4.0 > LogCleanerManager endless loop while compacting/cleaning seg

[jira] [Commented] (KAFKA-8764) LogCleanerManager endless loop while compacting/cleaning segments

[ https://issues.apache.org/jira/browse/KAFKA-8764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17012683#comment-17012683 ] Tomislav Rajakovic commented on KAFKA-8764: --- [~jnadler] and [~seva.f] so it see

[jira] [Comment Edited] (KAFKA-8764) LogCleanerManager endless loop while compacting/cleaning segments

[ https://issues.apache.org/jira/browse/KAFKA-8764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17012683#comment-17012683 ] Tomislav Rajakovic edited comment on KAFKA-8764 at 1/10/20 10:24 AM: --

[jira] [Commented] (KAFKA-9188) Flaky Test SslAdminClientIntegrationTest.testSynchronousAuthorizerAclUpdatesBlockRequestThreads

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

[jira] [Resolved] (KAFKA-9188) Flaky Test SslAdminClientIntegrationTest.testSynchronousAuthorizerAclUpdatesBlockRequestThreads

[ https://issues.apache.org/jira/browse/KAFKA-9188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-9188. --- Fix Version/s: 2.5.0 Reviewer: Manikumar Resolution: Fixed > Flaky Test > Ss

[jira] [Updated] (KAFKA-8764) LogCleanerManager endless loop while compacting/cleaning segments

[ https://issues.apache.org/jira/browse/KAFKA-8764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tomislav Rajakovic updated KAFKA-8764: -- Attachment: kafka2.4.0-KAFKA-8764.patch > LogCleanerManager endless loop while compacti

[jira] [Commented] (KAFKA-8764) LogCleanerManager endless loop while compacting/cleaning segments

[ https://issues.apache.org/jira/browse/KAFKA-8764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17012952#comment-17012952 ] Tomislav Rajakovic commented on KAFKA-8764: --- I think that this [^kafka2.4.0-KAF

[jira] [Issue Comment Deleted] (KAFKA-8764) LogCleanerManager endless loop while compacting/cleaning segments

[ https://issues.apache.org/jira/browse/KAFKA-8764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tomislav Rajakovic updated KAFKA-8764: -- Comment: was deleted (was: I think that this [^kafka2.4.0-KAFKA-8764.patch] resolves Lo

[jira] [Commented] (KAFKA-9152) Improve Sensor Retrieval

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

[jira] [Assigned] (KAFKA-9389) Document how to use kafka-reassign-partitions.sh to change log dirs for a partition

[ https://issues.apache.org/jira/browse/KAFKA-9389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mitchell reassigned KAFKA-9389: --- Assignee: Mitchell > Document how to use kafka-reassign-partitions.sh to change log dirs for a > pa

[jira] [Commented] (KAFKA-9152) Improve Sensor Retrieval

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

[jira] [Created] (KAFKA-9398) Kafka Streams main thread may not exit even after close timeout has passed

Bill Bejeck created KAFKA-9398: -- Summary: Kafka Streams main thread may not exit even after close timeout has passed Key: KAFKA-9398 URL: https://issues.apache.org/jira/browse/KAFKA-9398 Project: Kafka

[jira] [Updated] (KAFKA-9398) Kafka Streams main thread may not exit even after close timeout has passed

[ https://issues.apache.org/jira/browse/KAFKA-9398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-9398: --- Priority: Critical (was: Major) > Kafka Streams main thread may not exit even after close timeout ha

[jira] [Updated] (KAFKA-9398) Kafka Streams main thread may not exit even after close timeout has passed

[ https://issues.apache.org/jira/browse/KAFKA-9398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-9398: --- Description: Kafka Streams offers the KafkaStreams.close() method when shutting down a Kafka Streams

[jira] [Updated] (KAFKA-9398) Kafka Streams main thread may not exit even after close timeout has passed

[ https://issues.apache.org/jira/browse/KAFKA-9398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-9398: --- Description: Kafka Streams offers the KafkaStreams.close() method when shutting down a Kafka Streams

[jira] [Commented] (KAFKA-9398) Kafka Streams main thread may not exit even after close timeout has passed

[ https://issues.apache.org/jira/browse/KAFKA-9398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17013044#comment-17013044 ] Bill Bejeck commented on KAFKA-9398: A PR is available for this ticket [https://githu

[jira] [Updated] (KAFKA-8764) LogCleanerManager endless loop while compacting/cleaning segments

[ https://issues.apache.org/jira/browse/KAFKA-8764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Nadler updated KAFKA-8764: --- Attachment: Screen Shot 2020-01-10 at 8.38.25 AM.png > LogCleanerManager endless loop while compactin

[jira] [Commented] (KAFKA-8764) LogCleanerManager endless loop while compacting/cleaning segments

[ https://issues.apache.org/jira/browse/KAFKA-8764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17013052#comment-17013052 ] Jeff Nadler commented on KAFKA-8764: I just attached a graph of CPU usage in a small,

[jira] [Commented] (KAFKA-8764) LogCleanerManager endless loop while compacting/cleaning segments

[ https://issues.apache.org/jira/browse/KAFKA-8764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17013058#comment-17013058 ] Jun Rao commented on KAFKA-8764: [~trajakovic]: Thanks for the investigation. Normally, t

[jira] [Commented] (KAFKA-8764) LogCleanerManager endless loop while compacting/cleaning segments

[ https://issues.apache.org/jira/browse/KAFKA-8764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17013073#comment-17013073 ] Tomislav Rajakovic commented on KAFKA-8764: --- Hy [~junrao]. This issue happened

[jira] [Commented] (KAFKA-8764) LogCleanerManager endless loop while compacting/cleaning segments

[ https://issues.apache.org/jira/browse/KAFKA-8764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17013081#comment-17013081 ] Jun Rao commented on KAFKA-8764: [~trajakovic]: Thanks for providing the additional info.

[jira] [Commented] (KAFKA-9398) Kafka Streams main thread may not exit even after close timeout has passed

[ https://issues.apache.org/jira/browse/KAFKA-9398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17013108#comment-17013108 ] Matthias J. Sax commented on KAFKA-9398: The root cause seems to be https://issue

[jira] [Commented] (KAFKA-9398) Kafka Streams main thread may not exit even after close timeout has passed

[ https://issues.apache.org/jira/browse/KAFKA-9398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17013109#comment-17013109 ] Matthias J. Sax commented on KAFKA-9398: Other related issue: https://issues.apac

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=17013111#comment-17013111 ] Matthias J. Sax commented on KAFKA-3539: Seems KAFKA-3450 is a duplicate? > Kafk

[jira] [Commented] (KAFKA-3450) Producer blocks on send to topic that doesn't exist if auto create is disabled

[ https://issues.apache.org/jira/browse/KAFKA-3450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17013110#comment-17013110 ] Matthias J. Sax commented on KAFKA-3450: Seem KAFKA-3539 is a duplicate? > Produ

[jira] [Resolved] (KAFKA-6571) KafkaProducer.close(0) should be non-blocking

[ https://issues.apache.org/jira/browse/KAFKA-6571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6571. Resolution: Duplicate KIP-367 add `close(Duration)` with new non-blocking semantics:  [http

[jira] [Commented] (KAFKA-8178) KafkaProducer#send(ProducerRecord,Callback) may block for up to 60 seconds

[ https://issues.apache.org/jira/browse/KAFKA-8178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17013117#comment-17013117 ] Matthias J. Sax commented on KAFKA-8178: KAFKA-3450 is also related > KafkaProdu

[jira] [Commented] (KAFKA-9398) Kafka Streams main thread may not exit even after close timeout has passed

[ https://issues.apache.org/jira/browse/KAFKA-9398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17013115#comment-17013115 ] Matthias J. Sax commented on KAFKA-9398: Other one: https://issues.apache.org/jir

[jira] [Commented] (KAFKA-9393) DeleteRecords may cause extreme lock contention for large partition directories

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

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=17013151#comment-17013151 ] Gérald Quintana commented on KAFKA-9397: kafka-acl.sh doesn''t have --zookeeper a

[jira] [Commented] (KAFKA-9253) Test failure : ReassignPartitionsClusterTest.shouldListMovingPartitionsThroughApi

[ https://issues.apache.org/jira/browse/KAFKA-9253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17013152#comment-17013152 ] Bill Bejeck commented on KAFKA-9253: Seen again in  [https://builds.apache.org/job/ka

[jira] [Commented] (KAFKA-8764) LogCleanerManager endless loop while compacting/cleaning segments

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

[jira] [Commented] (KAFKA-8764) LogCleanerManager endless loop while compacting/cleaning segments

[ https://issues.apache.org/jira/browse/KAFKA-8764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17013187#comment-17013187 ] Tomislav Rajakovic commented on KAFKA-8764: --- [~jnadler] for now, try to "help"

[jira] [Created] (KAFKA-9399) Flaky Test BranchedMultiLevelRepartitionConnectedTopologyTest.testTopologyBuild

Matthias J. Sax created KAFKA-9399: -- Summary: Flaky Test BranchedMultiLevelRepartitionConnectedTopologyTest.testTopologyBuild Key: KAFKA-9399 URL: https://issues.apache.org/jira/browse/KAFKA-9399 Pro

[jira] [Commented] (KAFKA-6078) Investigate failure of ReassignPartitionsClusterTest.shouldExpandCluster

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

[jira] [Commented] (KAFKA-8770) Either switch to or add an option for emit-on-change

[ https://issues.apache.org/jira/browse/KAFKA-8770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17013230#comment-17013230 ] Richard Yu commented on KAFKA-8770: --- [~vvcephei] Actually, I did think of something whi

[jira] [Comment Edited] (KAFKA-8770) Either switch to or add an option for emit-on-change

[ https://issues.apache.org/jira/browse/KAFKA-8770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17013230#comment-17013230 ] Richard Yu edited comment on KAFKA-8770 at 1/10/20 10:09 PM: -

[jira] [Commented] (KAFKA-2758) Improve Offset Commit Behavior

[ https://issues.apache.org/jira/browse/KAFKA-2758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17013271#comment-17013271 ] Guozhang Wang commented on KAFKA-2758: -- We used to put it on hold especially for 1)

[jira] [Assigned] (KAFKA-7499) Extend ProductionExceptionHandler to cover serialization exceptions

[ https://issues.apache.org/jira/browse/KAFKA-7499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jbfletch reassigned KAFKA-7499: --- Assignee: jbfletch (was: Walker Carlson) > Extend ProductionExceptionHandler to cover serialization

[jira] [Commented] (KAFKA-8770) Either switch to or add an option for emit-on-change

[ https://issues.apache.org/jira/browse/KAFKA-8770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17013370#comment-17013370 ] Richard Yu commented on KAFKA-8770: --- I have created a draft KIP for this JIRA. [~xmar] 

[jira] [Comment Edited] (KAFKA-8770) Either switch to or add an option for emit-on-change

[ https://issues.apache.org/jira/browse/KAFKA-8770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17013370#comment-17013370 ] Richard Yu edited comment on KAFKA-8770 at 1/11/20 4:23 AM: I

[jira] [Commented] (KAFKA-8770) Either switch to or add an option for emit-on-change

[ https://issues.apache.org/jira/browse/KAFKA-8770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17013373#comment-17013373 ] John Roesler commented on KAFKA-8770: - Hey! Thanks for the effort on this. I looked

[jira] [Commented] (KAFKA-9376) Plugin class loader not found using MM2

[ https://issues.apache.org/jira/browse/KAFKA-9376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17013391#comment-17013391 ] yzhou commented on KAFKA-9376: -- [~ryannedolan] Here is a portion of the startup log: [ org