[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&focusedCommentId=16523303#comment-16523303 ] Dong Lin commented on KAFKA-7012: - Great to know that the fix works!   > Performance is

[jira] [Commented] (KAFKA-6949) alterReplicaLogDirs() should grab partition lock when accessing log of the future replica

[ https://issues.apache.org/jira/browse/KAFKA-6949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16523297#comment-16523297 ] Dong Lin commented on KAFKA-6949: - [~rsivaram] The patch has been merged into trunk. I op

[jira] [Updated] (KAFKA-6949) alterReplicaLogDirs() should grab partition lock when accessing log of the future replica

[ https://issues.apache.org/jira/browse/KAFKA-6949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-6949: Fix Version/s: 2.0.0 > alterReplicaLogDirs() should grab partition lock when accessing log of the > future

[jira] [Commented] (KAFKA-6949) alterReplicaLogDirs() should grab partition lock when accessing log of the future replica

[ https://issues.apache.org/jira/browse/KAFKA-6949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16523295#comment-16523295 ] ASF GitHub Bot commented on KAFKA-6949: --- lindong28 opened a new pull request #5293:

[jira] [Commented] (KAFKA-6949) alterReplicaLogDirs() should grab partition lock when accessing log of the future replica

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

[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&focusedCommentId=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&focusedCommentId=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&focusedCommentId=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&focusedCommentId=16523146#comment-16523146 ] Narayan Periwal commented on KAFKA-7026: [~vahid], Can this issue be there with R

[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&focusedCommentId=16523095#comment-16523095 ] Narayan Periwal commented on KAFKA-6681: [~steven.aerts], We are using RangeAssig

[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&focusedCommentId=16523074#comment-16523074 ] ASF GitHub Bot commented on KAFKA-7097: --- tedyu opened a new pull request #5292: KAF

[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&focusedCommentId=16523060#comment-16523060 ] ASF GitHub Bot commented on KAFKA-7026: --- vahidhashemian opened a new pull request #

[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: Improvement

[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&focusedCommentId=16522967#comment-16522967 ] Vahid Hashemian commented on KAFKA-7026: Thanks! Yes, this is a valid bug. Workin

[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&focusedCommentId=16522963#comment-16522963 ] Vahid Hashemian commented on KAFKA-7089: Thanks [~hachikuji]. I'll create a short

[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&focusedCommentId=16522943#comment-16522943 ] Dhruvil Shah commented on KAFKA-6098: - I don't think we can provide any formal guaran

[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&focusedCommentId=16522905#comment-16522905 ] ASF GitHub Bot commented on KAFKA-6591: --- hachikuji closed pull request #4618: KAFKA

[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&focusedCommentId=16522861#comment-16522861 ] rajadayalan perumalsamy commented on KAFKA-7012: Tried 1.1.2 version in o

[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  https://github.com/apac

[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&focusedCommentId=16522768#comment-16522768 ] Mayuresh Gharat commented on KAFKA-7096: [~lindong] : [https://github.com/apache/

[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&focusedCommentId=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&focusedCommentId=16522556#comment-16522556 ] Jason Gustafson commented on KAFKA-7089: Yeah, I think we should have a short KIP

[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&focusedCommentId=16522545#comment-16522545 ] Jason Gustafson commented on KAFKA-7092: Yes, you are probably hitting one of tho

[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&focusedCommentId=16522514#comment-16522514 ] ASF GitHub Bot commented on KAFKA-6986: --- guozhangwang closed pull request #5210: KA

[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&focusedCommentId=16522515#comment-16522515 ] ASF GitHub Bot commented on KAFKA-6986: --- shunge opened a new pull request #5210: KA

[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&focusedCommentId=16522504#comment-16522504 ] Jason Gustafson commented on KAFKA-7095: See [KIP-211|https://cwiki.apache.org/c

[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 Proj

[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&focusedCommentId=16522404#comment-16522404 ] Steven Aerts edited comment on KAFKA-7026 at 6/25/18 3:06 PM: -

[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&focusedCommentId=16522404#comment-16522404 ] Steven Aerts commented on KAFKA-7026: - I found three issues in kafka which are I thin

[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&focusedCommentId=16522397#comment-16522397 ] Yuancheng PENG commented on KAFKA-6717: --- Hi [~steven.aerts], I confirm that it's th

[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&focusedCommentId=16522373#comment-16522373 ] Steven Aerts commented on KAFKA-6681: - I think this problem is a duplicate of [KAFKA-

[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&focusedCommentId=16522372#comment-16522372 ] Steven Aerts commented on KAFKA-6717: - I think this problem is a duplicate of [KAFKA-

[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, whi

[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&focusedCommentId=16522114#comment-16522114 ] ASF GitHub Bot commented on KAFKA-7094: --- wangzzu opened a new pull request #5287: K

[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 Iss

[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&focusedCommentId=16522031#comment-16522031 ] Ted Yu commented on KAFKA-7088: --- Maybe set log level to DEBUG when you have a chance. Than

[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&focusedCommentId=16522004#comment-16522004 ] Lukasz Gluchowski commented on KAFKA-7088: -- [~yuzhih...@gmail.com] I turned TRAC

[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&focusedCommentId=16521948#comment-16521948 ] Wouter Bancken commented on KAFKA-6817: --- Is there any news on a solution/workaround