[jira] [Commented] (KAFKA-6879) Controller deadlock following session expiration

[ https://issues.apache.org/jira/browse/KAFKA-6879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17017827#comment-17017827 ] leibo commented on KAFKA-6879: -- Hello [~hachikuji],  I have met this issue on kafka 2.1.1 ma

[jira] [Assigned] (KAFKA-7787) Add error specifications to KAFKA-7609

[ https://issues.apache.org/jira/browse/KAFKA-7787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tom Bentley reassigned KAFKA-7787: -- Assignee: Tom Bentley > Add error specifications to KAFKA-7609 > -

[jira] [Commented] (KAFKA-7787) Add error specifications to KAFKA-7609

[ https://issues.apache.org/jira/browse/KAFKA-7787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17017873#comment-17017873 ] Tom Bentley commented on KAFKA-7787: [~cmccabe] I was thinking about this and have a

[jira] [Commented] (KAFKA-8406) kafka-topics throws wrong error on invalid configuration with bootstrap-server and alter config

[ https://issues.apache.org/jira/browse/KAFKA-8406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17017965#comment-17017965 ] Stanislav Savulchik commented on KAFKA-8406: [~enether] seems like the issue

[jira] [Commented] (KAFKA-8847) Deprecate and remove usage of supporting classes in kafka.security.auth

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

[jira] [Resolved] (KAFKA-8847) Deprecate and remove usage of supporting classes in kafka.security.auth

[ https://issues.apache.org/jira/browse/KAFKA-8847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-8847. --- Reviewer: Manikumar Resolution: Fixed > Deprecate and remove usage of supporting classe

[jira] [Resolved] (KAFKA-8865) KIP-504: New Java Authorizer API

[ https://issues.apache.org/jira/browse/KAFKA-8865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-8865. --- Fix Version/s: 2.4.0 Resolution: Fixed > KIP-504: New Java Authorizer API > --

[jira] [Commented] (KAFKA-9218) MirrorMaker 2 can fail to create topics

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

[jira] [Resolved] (KAFKA-9218) MirrorMaker 2 can fail to create topics

[ https://issues.apache.org/jira/browse/KAFKA-9218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mickael Maison resolved KAFKA-9218. --- Fix Version/s: 2.5.0 Resolution: Fixed > MirrorMaker 2 can fail to create topics > ---

[jira] [Commented] (KAFKA-2526) Console Producer / Consumer's serde config is not working

[ https://issues.apache.org/jira/browse/KAFKA-2526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17018099#comment-17018099 ] Tom Bentley commented on KAFKA-2526: [~mgharat] are you working on this, or intending

[jira] [Commented] (KAFKA-8532) controller-event-thread deadlock with zk-session-expiry-handler0

[ https://issues.apache.org/jira/browse/KAFKA-8532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17018152#comment-17018152 ] Ted Yu commented on KAFKA-8532: --- How about making the following change ? {code} diff --git

[jira] [Comment Edited] (KAFKA-8532) controller-event-thread deadlock with zk-session-expiry-handler0

[ https://issues.apache.org/jira/browse/KAFKA-8532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17018152#comment-17018152 ] Ted Yu edited comment on KAFKA-8532 at 1/17/20 4:13 PM: How about

[jira] [Commented] (KAFKA-8532) controller-event-thread deadlock with zk-session-expiry-handler0

[ https://issues.apache.org/jira/browse/KAFKA-8532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17018175#comment-17018175 ] Ted Yu commented on KAFKA-8532: --- Created https://github.com/apache/kafka/pull/7978 > contr

[jira] [Updated] (KAFKA-8532) controller-event-thread deadlock with zk-session-expiry-handler0

[ https://issues.apache.org/jira/browse/KAFKA-8532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Brian Byrne updated KAFKA-8532: --- Priority: Major (was: Blocker) > controller-event-thread deadlock with zk-session-expiry-handler0 >

[jira] [Updated] (KAFKA-8532) controller-event-thread deadlock with zk-session-expiry-handler0

[ https://issues.apache.org/jira/browse/KAFKA-8532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Brian Byrne updated KAFKA-8532: --- Priority: Blocker (was: Major) > controller-event-thread deadlock with zk-session-expiry-handler0 >

[jira] [Created] (KAFKA-9449) Producer's BufferPool may block the producer from closing.

Brian Byrne created KAFKA-9449: -- Summary: Producer's BufferPool may block the producer from closing. Key: KAFKA-9449 URL: https://issues.apache.org/jira/browse/KAFKA-9449 Project: Kafka Issue Ty

[jira] [Created] (KAFKA-9450) Decouple inner state flushing from committing with EOS

Sophie Blee-Goldman created KAFKA-9450: -- Summary: Decouple inner state flushing from committing with EOS Key: KAFKA-9450 URL: https://issues.apache.org/jira/browse/KAFKA-9450 Project: Kafka

[jira] [Commented] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17018259#comment-17018259 ] Raman Gupta commented on KAFKA-8803: And it happened again today with the same stream

[jira] [Commented] (KAFKA-8532) controller-event-thread deadlock with zk-session-expiry-handler0

[ https://issues.apache.org/jira/browse/KAFKA-8532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17018279#comment-17018279 ] Jun Rao commented on KAFKA-8532: [~lbdai3190]: Sorry for the late reply. Took a look at y

[jira] [Commented] (KAFKA-8532) controller-event-thread deadlock with zk-session-expiry-handler0

[ https://issues.apache.org/jira/browse/KAFKA-8532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17018352#comment-17018352 ] Ted Yu commented on KAFKA-8532: --- Looking at KafkaController.scala in trunk, I don't see Ex

[jira] [Commented] (KAFKA-9449) Producer's BufferPool may block the producer from closing.

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

[jira] [Resolved] (KAFKA-9449) Producer's BufferPool may block the producer from closing.

[ https://issues.apache.org/jira/browse/KAFKA-9449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9449. Fix Version/s: 2.4.1 Resolution: Fixed > Producer's BufferPool may block the produce

[jira] [Commented] (KAFKA-8532) controller-event-thread deadlock with zk-session-expiry-handler0

[ https://issues.apache.org/jira/browse/KAFKA-8532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17018368#comment-17018368 ] Ted Yu commented on KAFKA-8532: --- Looking at js2.log , I am not sure deadlock was observed.

[jira] [Commented] (KAFKA-9329) KafkaController::replicasAreValid should return error

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

[jira] [Resolved] (KAFKA-9329) KafkaController::replicasAreValid should return error

[ https://issues.apache.org/jira/browse/KAFKA-9329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9329. Fix Version/s: 2.5.0 Resolution: Fixed > KafkaController::replicasAreValid should re

[jira] [Commented] (KAFKA-9338) Incremental fetch sessions do not maintain or use leader epoch for fencing purposes

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

[jira] [Comment Edited] (KAFKA-8532) controller-event-thread deadlock with zk-session-expiry-handler0

[ https://issues.apache.org/jira/browse/KAFKA-8532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17018368#comment-17018368 ] Ted Yu edited comment on KAFKA-8532 at 1/17/20 10:42 PM: - Looking

[jira] [Resolved] (KAFKA-9338) Incremental fetch sessions do not maintain or use leader epoch for fencing purposes

[ https://issues.apache.org/jira/browse/KAFKA-9338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9338. Fix Version/s: 2.5.0 Resolution: Fixed Marking this just as 2.5 for now. If we don't

[jira] [Created] (KAFKA-9451) Pass consumer group metadata to producer on commit

Matthias J. Sax created KAFKA-9451: -- Summary: Pass consumer group metadata to producer on commit Key: KAFKA-9451 URL: https://issues.apache.org/jira/browse/KAFKA-9451 Project: Kafka Issue Ty

[jira] [Assigned] (KAFKA-9451) Pass consumer group metadata to producer on commit

[ https://issues.apache.org/jira/browse/KAFKA-9451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-9451: -- Assignee: Matthias J. Sax > Pass consumer group metadata to producer on commit > -

[jira] [Updated] (KAFKA-9451) Pass consumer group metadata to producer on commit

[ https://issues.apache.org/jira/browse/KAFKA-9451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9451: --- Description: Using producer per thread EOS design, we need to pass the consumer group metadat

[jira] [Commented] (KAFKA-5381) ERROR Uncaught exception in scheduled task 'delete-expired-consumer-offsets' (kafka.utils.KafkaScheduler)

[ https://issues.apache.org/jira/browse/KAFKA-5381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17018380#comment-17018380 ] mjuarez commented on KAFKA-5381: We ran into the same exception with kafka version 1.1.1.

[jira] [Commented] (KAFKA-7658) Add KStream#toTable to the Streams DSL

[ https://issues.apache.org/jira/browse/KAFKA-7658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17018432#comment-17018432 ] highluck commented on KAFKA-7658: - I wanted to say Is it okay if I pr?! > Add KStream#t

[jira] [Commented] (KAFKA-9440) Add ConsumerGroupCommand to delete static members

[ https://issues.apache.org/jira/browse/KAFKA-9440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17018448#comment-17018448 ] Xue Liu commented on KAFKA-9440: Hi [~bchen225242], I am pretty new to Kafka community, c

[jira] [Commented] (KAFKA-7658) Add KStream#toTable to the Streams DSL

[ https://issues.apache.org/jira/browse/KAFKA-7658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17018460#comment-17018460 ] Matthias J. Sax commented on KAFKA-7658: Yes, it's ok to pick this up and assign

[jira] [Comment Edited] (KAFKA-8532) controller-event-thread deadlock with zk-session-expiry-handler0

[ https://issues.apache.org/jira/browse/KAFKA-8532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17018368#comment-17018368 ] Ted Yu edited comment on KAFKA-8532 at 1/18/20 2:21 AM: Looking a

[jira] [Comment Edited] (KAFKA-8532) controller-event-thread deadlock with zk-session-expiry-handler0

[ https://issues.apache.org/jira/browse/KAFKA-8532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17018368#comment-17018368 ] Ted Yu edited comment on KAFKA-8532 at 1/18/20 2:22 AM: Looking a

[jira] [Comment Edited] (KAFKA-8532) controller-event-thread deadlock with zk-session-expiry-handler0

[ https://issues.apache.org/jira/browse/KAFKA-8532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17018368#comment-17018368 ] Ted Yu edited comment on KAFKA-8532 at 1/18/20 2:26 AM: Looking a

[jira] [Commented] (KAFKA-9450) Decouple inner state flushing from committing with EOS

[ https://issues.apache.org/jira/browse/KAFKA-9450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17018501#comment-17018501 ] John Roesler commented on KAFKA-9450: - This reminds me of an idea I proposed a while