[jira] [Comment Edited] (KAFKA-6681) Two instances of kafka consumer reading the same partition within a consumer group

[ https://issues.apache.org/jira/browse/KAFKA-6681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16523095#comment-16523095 ] Narayan Periwal edited comment on KAFKA-6681 at 6/26/18 4:02 AM: -

[jira] [Comment Edited] (KAFKA-7026) Sticky assignor could assign a partition to multiple consumers

[ https://issues.apache.org/jira/browse/KAFKA-7026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16523146#comment-16523146 ] Narayan Periwal edited comment on KAFKA-7026 at 6/26/18 4:01 AM: -

[jira] [Comment Edited] (KAFKA-7026) Sticky assignor could assign a partition to multiple consumers

[ https://issues.apache.org/jira/browse/KAFKA-7026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16523146#comment-16523146 ] Narayan Periwal edited comment on KAFKA-7026 at 6/26/18 3:59 AM: -

[jira] [Commented] (KAFKA-7026) Sticky assignor could assign a partition to multiple consumers

[ https://issues.apache.org/jira/browse/KAFKA-7026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16523146#comment-16523146 ] Narayan Periwal commented on KAFKA-7026: [~vahid], Can this issue be there with RangeAssignor as

[jira] [Commented] (KAFKA-6681) Two instances of kafka consumer reading the same partition within a consumer group

[ https://issues.apache.org/jira/browse/KAFKA-6681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16523095#comment-16523095 ] Narayan Periwal commented on KAFKA-6681: [~steven.aerts], We are using RangeAssignor(which is the

[jira] [Commented] (KAFKA-7097) VerifiableProducer does not work properly with --message-create-time argument

[ https://issues.apache.org/jira/browse/KAFKA-7097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16523074#comment-16523074 ] ASF GitHub Bot commented on KAFKA-7097: --- tedyu opened a new pull request #5292: KAFKA-7097

[jira] [Commented] (KAFKA-7026) Sticky assignor could assign a partition to multiple consumers

[ https://issues.apache.org/jira/browse/KAFKA-7026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16523060#comment-16523060 ] ASF GitHub Bot commented on KAFKA-7026: --- vahidhashemian opened a new pull request #5291:

[jira] [Created] (KAFKA-7098) Improve accuracy of the log cleaner throttle rate

Dong Lin created KAFKA-7098: --- Summary: Improve accuracy of the log cleaner throttle rate Key: KAFKA-7098 URL: https://issues.apache.org/jira/browse/KAFKA-7098 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-7026) Sticky assignor could assign a partition to multiple consumers

[ https://issues.apache.org/jira/browse/KAFKA-7026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16522967#comment-16522967 ] Vahid Hashemian commented on KAFKA-7026: Thanks! Yes, this is a valid bug. Working on a PR and

[jira] [Commented] (KAFKA-7089) Extend `kafka-consumer-groups.sh` to show "beginning offsets"

[ https://issues.apache.org/jira/browse/KAFKA-7089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16522963#comment-16522963 ] Vahid Hashemian commented on KAFKA-7089: Thanks [~hachikuji]. I'll create a short KIP. > Extend

[jira] [Commented] (KAFKA-6098) Delete and Re-create topic operation could result in race condition

[ https://issues.apache.org/jira/browse/KAFKA-6098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16522943#comment-16522943 ] Dhruvil Shah commented on KAFKA-6098: - I don't think we can provide any formal guarantees for these

[jira] [Commented] (KAFKA-6591) Move check for super user in SimpleAclProvider before ACL evaluation

[ https://issues.apache.org/jira/browse/KAFKA-6591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16522905#comment-16522905 ] ASF GitHub Bot commented on KAFKA-6591: --- hachikuji closed pull request #4618: KAFKA-6591: Move

[jira] [Closed] (KAFKA-6978) Make Streams Window retention time strict

[ https://issues.apache.org/jira/browse/KAFKA-6978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler closed KAFKA-6978. --- > Make Streams Window retention time strict > - > >

[jira] [Commented] (KAFKA-7012) Performance issue upgrading to kafka 1.0.1 or 1.1

[ https://issues.apache.org/jira/browse/KAFKA-7012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16522861#comment-16522861 ] rajadayalan perumalsamy commented on KAFKA-7012: Tried 1.1.2 version in our kafka

[jira] [Resolved] (KAFKA-6978) Make Streams Window retention time strict

[ https://issues.apache.org/jira/browse/KAFKA-6978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-6978. - Resolution: Fixed Fix Version/s: 2.1.0 This feature was merged in 

[jira] [Commented] (KAFKA-7096) Consumer should drop the data for unassigned topic partitions

[ https://issues.apache.org/jira/browse/KAFKA-7096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16522768#comment-16522768 ] Mayuresh Gharat commented on KAFKA-7096: [~lindong] : [https://github.com/apache/kafka/pull/5289]

[jira] [Created] (KAFKA-7097) VerifiableProducer does not work properly with --message-create-time argument

Jasper Knulst created KAFKA-7097: Summary: VerifiableProducer does not work properly with --message-create-time argument Key: KAFKA-7097 URL: https://issues.apache.org/jira/browse/KAFKA-7097 Project:

[jira] [Comment Edited] (KAFKA-6817) UnknownProducerIdException when writing messages with old timestamps

[ https://issues.apache.org/jira/browse/KAFKA-6817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16518766#comment-16518766 ] Collin Scangarella edited comment on KAFKA-6817 at 6/25/18 6:21 PM:

[jira] [Created] (KAFKA-7096) Consumer should drop the data for unassigned topic partitions

Mayuresh Gharat created KAFKA-7096: -- Summary: Consumer should drop the data for unassigned topic partitions Key: KAFKA-7096 URL: https://issues.apache.org/jira/browse/KAFKA-7096 Project: Kafka

[jira] [Commented] (KAFKA-7089) Extend `kafka-consumer-groups.sh` to show "beginning offsets"

[ https://issues.apache.org/jira/browse/KAFKA-7089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16522556#comment-16522556 ] Jason Gustafson commented on KAFKA-7089: Yeah, I think we should have a short KIP. Seems

[jira] [Commented] (KAFKA-7092) Multiple topics (including __consumer_offsets) have not been cleaned for a few months

[ https://issues.apache.org/jira/browse/KAFKA-7092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16522545#comment-16522545 ] Jason Gustafson commented on KAFKA-7092: Yes, you are probably hitting one of those bugs. The

[jira] [Commented] (KAFKA-6986) Export Admin Client metrics through Stream Threads

[ https://issues.apache.org/jira/browse/KAFKA-6986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16522514#comment-16522514 ] ASF GitHub Bot commented on KAFKA-6986: --- guozhangwang closed pull request #5210: KAFKA-6986: Export

[jira] [Commented] (KAFKA-6986) Export Admin Client metrics through Stream Threads

[ https://issues.apache.org/jira/browse/KAFKA-6986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16522515#comment-16522515 ] ASF GitHub Bot commented on KAFKA-6986: --- shunge opened a new pull request #5210: KAFKA-6986: Export

[jira] [Commented] (KAFKA-7095) Low traffic consumer is not consuming messages after the offsets is deleted by Kafka

[ https://issues.apache.org/jira/browse/KAFKA-7095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16522504#comment-16522504 ] Jason Gustafson commented on KAFKA-7095: See

[jira] [Created] (KAFKA-7095) Low traffic consumer is not consuming messages after the offsets is deleted by Kafka

Aldo Sinanaj created KAFKA-7095: --- Summary: Low traffic consumer is not consuming messages after the offsets is deleted by Kafka Key: KAFKA-7095 URL: https://issues.apache.org/jira/browse/KAFKA-7095

[jira] [Comment Edited] (KAFKA-7026) Sticky assignor could assign a partition to multiple consumers

[ https://issues.apache.org/jira/browse/KAFKA-7026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16522404#comment-16522404 ] Steven Aerts edited comment on KAFKA-7026 at 6/25/18 3:06 PM: -- I found three

[jira] [Commented] (KAFKA-7026) Sticky assignor could assign a partition to multiple consumers

[ https://issues.apache.org/jira/browse/KAFKA-7026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16522404#comment-16522404 ] Steven Aerts commented on KAFKA-7026: - I found three issues in kafka which are I think all the same.

[jira] [Commented] (KAFKA-6717) TopicPartition Assined twice to a consumer group for 2 consumer instances

[ https://issues.apache.org/jira/browse/KAFKA-6717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16522397#comment-16522397 ] Yuancheng PENG commented on KAFKA-6717: --- Hi [~steven.aerts], I confirm that it's the same issue as 

[jira] [Commented] (KAFKA-6681) Two instances of kafka consumer reading the same partition within a consumer group

[ https://issues.apache.org/jira/browse/KAFKA-6681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16522373#comment-16522373 ] Steven Aerts commented on KAFKA-6681: - I think this problem is a duplicate of [KAFKA-7026]. > Two

[jira] [Commented] (KAFKA-6717) TopicPartition Assined twice to a consumer group for 2 consumer instances

[ https://issues.apache.org/jira/browse/KAFKA-6717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16522372#comment-16522372 ] Steven Aerts commented on KAFKA-6717: - I think this problem is a duplicate of [KAFKA-7026]. >

[jira] [Updated] (KAFKA-7094) Variate should unify code style in one method, and use camel name

[ https://issues.apache.org/jira/browse/KAFKA-7094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matt Wang updated KAFKA-7094: - Description: In one method, there are two variates, partitionsTobeLeader and partitionsToBeFollower,

[jira] [Commented] (KAFKA-7094) Variate should unify code style in one method, and use camel name

[ https://issues.apache.org/jira/browse/KAFKA-7094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16522114#comment-16522114 ] ASF GitHub Bot commented on KAFKA-7094: --- wangzzu opened a new pull request #5287: KAFKA-7094:

[jira] [Created] (KAFKA-7094) Variate should unify code style in one method, and use camel name

Matt Wang created KAFKA-7094: Summary: Variate should unify code style in one method, and use camel name Key: KAFKA-7094 URL: https://issues.apache.org/jira/browse/KAFKA-7094 Project: Kafka

[jira] [Commented] (KAFKA-7088) Kafka streams thread waits infinitely on transaction init

[ https://issues.apache.org/jira/browse/KAFKA-7088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16522031#comment-16522031 ] Ted Yu commented on KAFKA-7088: --- Maybe set log level to DEBUG when you have a chance. Thanks > Kafka

[jira] [Commented] (KAFKA-7088) Kafka streams thread waits infinitely on transaction init

[ https://issues.apache.org/jira/browse/KAFKA-7088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16522004#comment-16522004 ] Lukasz Gluchowski commented on KAFKA-7088: -- [~yuzhih...@gmail.com] I turned TRACE logging on non

[jira] [Commented] (KAFKA-6817) UnknownProducerIdException when writing messages with old timestamps

[ https://issues.apache.org/jira/browse/KAFKA-6817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16521948#comment-16521948 ] Wouter Bancken commented on KAFKA-6817: --- Is there any news on a solution/workaround for clients not