[jira] [Commented] (KAFKA-8461) Flakey test UncleanLeaderElectionTest#testUncleanLeaderElectionDisabledByTopicOverride

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

[jira] [Created] (KAFKA-8486) How to commit offset via Kafka

Stanislav created KAFKA-8486: - Summary: How to commit offset via Kafka Key: KAFKA-8486 URL: https://issues.apache.org/jira/browse/KAFKA-8486 Project: Kafka Issue Type: Wish Components

[jira] [Updated] (KAFKA-8486) How to commit offset via Kafka

[ https://issues.apache.org/jira/browse/KAFKA-8486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav updated KAFKA-8486: -- Description: from kafka import KafkaConsumer, TopicPartition, OffsetAndMetadata from json import loads

[jira] [Updated] (KAFKA-8486) How to commit offset via Kafka

[ https://issues.apache.org/jira/browse/KAFKA-8486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav updated KAFKA-8486: -- Description: from kafka import KafkaConsumer, TopicPartition, OffsetAndMetadata from json import loads

[jira] [Commented] (KAFKA-8486) How to commit offset via Kafka

[ https://issues.apache.org/jira/browse/KAFKA-8486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16856484#comment-16856484 ] Stanislav commented on KAFKA-8486: --- Could you please provide advice. I hope what you c

[jira] [Commented] (KAFKA-7748) Add wall clock TimeDefinition for suppression of intermediate events

[ https://issues.apache.org/jira/browse/KAFKA-7748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16856531#comment-16856531 ] Juha Heljoranta commented on KAFKA-7748: Any updates on this? > Add wall clock T

[jira] [Commented] (KAFKA-8450) Augment processed in MockProcessor as KeyValueAndTimestamp

[ https://issues.apache.org/jira/browse/KAFKA-8450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16856627#comment-16856627 ] SuryaTeja Duggi commented on KAFKA-8450: I see this is being used in process() fu

[jira] [Comment Edited] (KAFKA-8450) Augment processed in MockProcessor as KeyValueAndTimestamp

[ https://issues.apache.org/jira/browse/KAFKA-8450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16856627#comment-16856627 ] SuryaTeja Duggi edited comment on KAFKA-8450 at 6/5/19 1:30 PM: ---

[jira] [Commented] (KAFKA-6598) Kafka to support using ETCD beside Zookeeper

[ https://issues.apache.org/jira/browse/KAFKA-6598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16856770#comment-16856770 ] Balint Molnar commented on KAFKA-6598: -- It's been more than a year since we are wait

[jira] [Created] (KAFKA-8487) Consumer should not resetGeneration upon REBALANCE_IN_PROGRESS in commit response handler

Guozhang Wang created KAFKA-8487: Summary: Consumer should not resetGeneration upon REBALANCE_IN_PROGRESS in commit response handler Key: KAFKA-8487 URL: https://issues.apache.org/jira/browse/KAFKA-8487

[jira] [Updated] (KAFKA-3816) Provide more context in Kafka Connect log messages using MDC

[ https://issues.apache.org/jira/browse/KAFKA-3816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe updated KAFKA-3816: --- Fix Version/s: 2.3.0 > Provide more context in Kafka Connect log messages using MDC > ---

[jira] [Assigned] (KAFKA-3816) Provide more context in Kafka Connect log messages using MDC

[ https://issues.apache.org/jira/browse/KAFKA-3816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe reassigned KAFKA-3816: -- Assignee: Randall Hauch > Provide more context in Kafka Connect log messages using MDC

[jira] [Resolved] (KAFKA-3816) Provide more context in Kafka Connect log messages using MDC

[ https://issues.apache.org/jira/browse/KAFKA-3816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe resolved KAFKA-3816. Resolution: Fixed > Provide more context in Kafka Connect log messages using MDC >

[jira] [Resolved] (KAFKA-8265) Connect Client Config Override policy

[ https://issues.apache.org/jira/browse/KAFKA-8265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe resolved KAFKA-8265. Resolution: Fixed Fix Version/s: 2.3 > Connect Client Config Override policy > -

[jira] [Created] (KAFKA-8488) FetchSessionHandler logging create 73 mb allocation in TLAB which could be no op

Wenshuai Hou created KAFKA-8488: --- Summary: FetchSessionHandler logging create 73 mb allocation in TLAB which could be no op Key: KAFKA-8488 URL: https://issues.apache.org/jira/browse/KAFKA-8488 Project

[jira] [Commented] (KAFKA-8488) FetchSessionHandler logging create 73 mb allocation in TLAB which could be no op

[ https://issues.apache.org/jira/browse/KAFKA-8488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16856925#comment-16856925 ] Wenshuai Hou commented on KAFKA-8488: - the logging string allocation could be no op w

[jira] [Commented] (KAFKA-8488) FetchSessionHandler logging create 73 mb allocation in TLAB which could be no op

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

[jira] [Commented] (KAFKA-8486) How to commit offset via Kafka

[ https://issues.apache.org/jira/browse/KAFKA-8486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16856952#comment-16856952 ] Matthias J. Sax commented on KAFKA-8486: Please ask questions on the user mailing

[jira] [Resolved] (KAFKA-8486) How to commit offset via Kafka

[ https://issues.apache.org/jira/browse/KAFKA-8486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-8486. Resolution: Invalid > How to commit offset via Kafka > --- > >

[jira] [Commented] (KAFKA-8438) Add API to allow user to define end behavior of consumer failure

[ https://issues.apache.org/jira/browse/KAFKA-8438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16856999#comment-16856999 ] Richard Yu commented on KAFKA-8438: --- Sure [~bchen225242] will look into it and see what

[jira] [Commented] (KAFKA-8448) Too many kafka.log.Log instances (Memory Leak)

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

[jira] [Updated] (KAFKA-8487) Consumer should not resetGeneration upon REBALANCE_IN_PROGRESS in commit response handler

[ https://issues.apache.org/jira/browse/KAFKA-8487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-8487: - Priority: Blocker (was: Major) > Consumer should not resetGeneration upon REBALANCE_IN_PROGRESS

[jira] [Updated] (KAFKA-8487) Consumer should not resetGeneration upon REBALANCE_IN_PROGRESS in commit response handler

[ https://issues.apache.org/jira/browse/KAFKA-8487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-8487: - Issue Type: Bug (was: Improvement) > Consumer should not resetGeneration upon REBALANCE_IN_PROGR

[jira] [Commented] (KAFKA-8433) Give the opportunity to use serializers and deserializers with IntegrationTestUtils

[ https://issues.apache.org/jira/browse/KAFKA-8433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16857022#comment-16857022 ] Anthony C commented on KAFKA-8433: -- [~mjsax] everything works with topologies testing ap

[jira] [Resolved] (KAFKA-8433) Give the opportunity to use serializers and deserializers with IntegrationTestUtils

[ https://issues.apache.org/jira/browse/KAFKA-8433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anthony C resolved KAFKA-8433. -- Resolution: Won't Fix > Give the opportunity to use serializers and deserializers with > IntegrationTe

[jira] [Commented] (KAFKA-8433) Give the opportunity to use serializers and deserializers with IntegrationTestUtils

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

[jira] [Commented] (KAFKA-8433) Give the opportunity to use serializers and deserializers with IntegrationTestUtils

[ https://issues.apache.org/jira/browse/KAFKA-8433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16857032#comment-16857032 ] Matthias J. Sax commented on KAFKA-8433: Thanks for the feedback [~callaertanthon

[jira] [Commented] (KAFKA-8305) AdminClient should support creating topics with default partitions and replication factor

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

[jira] [Resolved] (KAFKA-8305) AdminClient should support creating topics with default partitions and replication factor

[ https://issues.apache.org/jira/browse/KAFKA-8305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-8305. Resolution: Fixed Assignee: Almog Gavra Fix Version/s: 2.4.0 > AdminClient

[jira] [Commented] (KAFKA-8386) Use COORDINATOR_NOT_AVAILABLE to replace UNKNOWN_MEMBER_ID when the group is not available

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

[jira] [Commented] (KAFKA-8421) Allow consumer.poll() to return data in the middle of rebalance

[ https://issues.apache.org/jira/browse/KAFKA-8421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16857088#comment-16857088 ] Richard Yu commented on KAFKA-8421: --- [~guozhang] There are a couple of simple approache

[jira] [Comment Edited] (KAFKA-8421) Allow consumer.poll() to return data in the middle of rebalance

[ https://issues.apache.org/jira/browse/KAFKA-8421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16857088#comment-16857088 ] Richard Yu edited comment on KAFKA-8421 at 6/5/19 9:32 PM: --- [~g

[jira] [Comment Edited] (KAFKA-8421) Allow consumer.poll() to return data in the middle of rebalance

[ https://issues.apache.org/jira/browse/KAFKA-8421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16857088#comment-16857088 ] Richard Yu edited comment on KAFKA-8421 at 6/5/19 9:32 PM: --- [~g

[jira] [Commented] (KAFKA-8400) Do not update follower replica state if the log read failed

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

[jira] [Resolved] (KAFKA-8400) Do not update follower replica state if the log read failed

[ https://issues.apache.org/jira/browse/KAFKA-8400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-8400. Resolution: Fixed Fix Version/s: 2.4.0 > Do not update follower replica state if the

[jira] [Resolved] (KAFKA-8386) Use COORDINATOR_NOT_AVAILABLE to replace UNKNOWN_MEMBER_ID when the group is not available

[ https://issues.apache.org/jira/browse/KAFKA-8386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-8386. Resolution: Fixed Fix Version/s: 2.3.0 > Use COORDINATOR_NOT_AVAILABLE to replace UN

[jira] [Comment Edited] (KAFKA-8421) Allow consumer.poll() to return data in the middle of rebalance

[ https://issues.apache.org/jira/browse/KAFKA-8421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16857088#comment-16857088 ] Richard Yu edited comment on KAFKA-8421 at 6/5/19 11:13 PM: [

[jira] [Commented] (KAFKA-8421) Allow consumer.poll() to return data in the middle of rebalance

[ https://issues.apache.org/jira/browse/KAFKA-8421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16857147#comment-16857147 ] Richard Yu commented on KAFKA-8421: --- I think that we could extend this issue to account

[jira] [Commented] (KAFKA-8485) Kafka connect worker does not respond when kafka broker goes down with data streaming in progress

[ https://issues.apache.org/jira/browse/KAFKA-8485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16857151#comment-16857151 ] Konstantine Karantasis commented on KAFKA-8485: --- [~kaushik srinivas] are yo

[jira] [Commented] (KAFKA-8487) Consumer should not resetGeneration upon REBALANCE_IN_PROGRESS in commit response handler

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

[jira] [Created] (KAFKA-8489) Remove group immediately when DeleteGroup request could be completed

Boyang Chen created KAFKA-8489: -- Summary: Remove group immediately when DeleteGroup request could be completed Key: KAFKA-8489 URL: https://issues.apache.org/jira/browse/KAFKA-8489 Project: Kafka

[jira] [Created] (KAFKA-8490) Use `Migrated` and `Deleted` state to replace consumer group `Dead` state

Boyang Chen created KAFKA-8490: -- Summary: Use `Migrated` and `Deleted` state to replace consumer group `Dead` state Key: KAFKA-8490 URL: https://issues.apache.org/jira/browse/KAFKA-8490 Project: Kafka

[jira] [Assigned] (KAFKA-8489) Remove group immediately when DeleteGroup request could be completed

[ https://issues.apache.org/jira/browse/KAFKA-8489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-8489: -- Assignee: Boyang Chen > Remove group immediately when DeleteGroup request could be completed >

[jira] [Created] (KAFKA-8491) Bump up Consumer Protocol to v2 (part 1)

Guozhang Wang created KAFKA-8491: Summary: Bump up Consumer Protocol to v2 (part 1) Key: KAFKA-8491 URL: https://issues.apache.org/jira/browse/KAFKA-8491 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-8492) Modify ConsumerCoordinator Algorithm with incremental protocol (part 2)

Guozhang Wang created KAFKA-8492: Summary: Modify ConsumerCoordinator Algorithm with incremental protocol (part 2) Key: KAFKA-8492 URL: https://issues.apache.org/jira/browse/KAFKA-8492 Project: Kafka

[jira] [Created] (KAFKA-8493) Add PartitionsLost API in RebalanceListener

Guozhang Wang created KAFKA-8493: Summary: Add PartitionsLost API in RebalanceListener Key: KAFKA-8493 URL: https://issues.apache.org/jira/browse/KAFKA-8493 Project: Kafka Issue Type: Sub-tas

[jira] [Updated] (KAFKA-8493) Add PartitionsLost API in RebalanceListener (part 3)

[ https://issues.apache.org/jira/browse/KAFKA-8493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-8493: - Summary: Add PartitionsLost API in RebalanceListener (part 3) (was: Add PartitionsLost API in Re

[jira] [Created] (KAFKA-8494) Refactor Consumer#StickyAssignor to support incremental protocol (part 4)

Guozhang Wang created KAFKA-8494: Summary: Refactor Consumer#StickyAssignor to support incremental protocol (part 4) Key: KAFKA-8494 URL: https://issues.apache.org/jira/browse/KAFKA-8494 Project: Kafk

[jira] [Created] (KAFKA-8495) Make Round-robin / RangeAssignor to be "sticky" (part 5)

Guozhang Wang created KAFKA-8495: Summary: Make Round-robin / RangeAssignor to be "sticky" (part 5) Key: KAFKA-8495 URL: https://issues.apache.org/jira/browse/KAFKA-8495 Project: Kafka Issue

[jira] [Created] (KAFKA-8496) Add system test for compatibility and upgrade path (part 6)

Guozhang Wang created KAFKA-8496: Summary: Add system test for compatibility and upgrade path (part 6) Key: KAFKA-8496 URL: https://issues.apache.org/jira/browse/KAFKA-8496 Project: Kafka Is

[jira] [Commented] (KAFKA-8495) Make Round-robin / RangeAssignor to be "sticky" (part 5)

[ https://issues.apache.org/jira/browse/KAFKA-8495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16857233#comment-16857233 ] Boyang Chen commented on KAFKA-8495: FYI we do have one ongoing diff to make those co

[jira] [Created] (KAFKA-8497) kafka streams application占用内存很高

sunqing created KAFKA-8497: -- Summary: kafka streams application占用内存很高 Key: KAFKA-8497 URL: https://issues.apache.org/jira/browse/KAFKA-8497 Project: Kafka Issue Type: Bug Components: strea

[jira] [Commented] (KAFKA-8489) Remove group immediately when DeleteGroup request could be completed

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