[jira] [Created] (KAFKA-6323) punctuate with WALL_CLOCK_TIME triggered immediately

Frederic Arno created KAFKA-6323: Summary: punctuate with WALL_CLOCK_TIME triggered immediately Key: KAFKA-6323 URL: https://issues.apache.org/jira/browse/KAFKA-6323 Project: Kafka Issue

[jira] [Updated] (KAFKA-6316) Kafka Rebalancing issues when I kill one consumer

[ https://issues.apache.org/jira/browse/KAFKA-6316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Krishan updated KAFKA-6316: --- Description: There is a very weird flow happening in the following case I have 6 consumer processes running

[jira] [Commented] (KAFKA-6322) Error deleting log for topic, all log dirs failed.

[ https://issues.apache.org/jira/browse/KAFKA-6322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16281270#comment-16281270 ] Ted Yu commented on KAFKA-6322: --- Seems to be same problem as KAFKA-6075 > Error deleting log for topic, all

[jira] [Resolved] (KAFKA-5878) Add sensor for queue size of the controller-event-thread

[ https://issues.apache.org/jira/browse/KAFKA-5878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin resolved KAFKA-5878. - Resolution: Duplicate This metric will be added in https://issues.apache.org/jira/browse/KAFKA-3473. >

[jira] [Updated] (KAFKA-3473) KIP-237: More Controller Health Metrics

[ https://issues.apache.org/jira/browse/KAFKA-3473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-3473: Description: Currently controller appends the requests to brokers into controller channel manager queue

[jira] [Updated] (KAFKA-3473) KIP-237: More Controller Health Metrics

[ https://issues.apache.org/jira/browse/KAFKA-3473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-3473: Description: Currently controller appends the requests to brokers into controller channel manager queue

[jira] [Updated] (KAFKA-3473) KIP-237: More Controller Health Metrics

[ https://issues.apache.org/jira/browse/KAFKA-3473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-3473: Affects Version/s: (was: 0.10.0.0) 1.0.1 > KIP-237: More Controller Health

[jira] [Updated] (KAFKA-3473) KIP-237: More Controller Health Metrics

[ https://issues.apache.org/jira/browse/KAFKA-3473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-3473: Summary: KIP-237: More Controller Health Metrics (was: Add controller channel manager request queue time

[jira] [Assigned] (KAFKA-6298) Line numbers on log messages are incorrect

[ https://issues.apache.org/jira/browse/KAFKA-6298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reassigned KAFKA-6298: -- Assignee: Narendra Kumar > Line numbers on log messages are incorrect >

[jira] [Commented] (KAFKA-6298) Line numbers on log messages are incorrect

[ https://issues.apache.org/jira/browse/KAFKA-6298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16281204#comment-16281204 ] Jason Gustafson commented on KAFKA-6298: [~Narendra Kumar] Thanks. I went ahead and assigned you.

[jira] [Comment Edited] (KAFKA-5027) Kafka Controller Redesign

[ https://issues.apache.org/jira/browse/KAFKA-5027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16216153#comment-16216153 ] Ismael Juma edited comment on KAFKA-5027 at 12/7/17 12:35 AM: -- For the 1.1.0

[jira] [Commented] (KAFKA-5382) Log recovery can fail if topic names contain one of the index suffixes

[ https://issues.apache.org/jira/browse/KAFKA-5382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16281152#comment-16281152 ] Robert P. Thille commented on KAFKA-5382: - Logged in just to add 0.9.0.1 to the affected versions,

[jira] [Resolved] (KAFKA-6065) Add ZooKeeperRequestLatencyMs to KafkaZkClient

[ https://issues.apache.org/jira/browse/KAFKA-6065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-6065. Resolution: Fixed > Add ZooKeeperRequestLatencyMs to KafkaZkClient >

[jira] [Updated] (KAFKA-6065) Add ZooKeeperRequestLatencyMs to KafkaZkClient

[ https://issues.apache.org/jira/browse/KAFKA-6065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-6065: --- Description: Among other things, KIP-188 added latency metrics to ZkUtils. We should add the same

[jira] [Updated] (KAFKA-6065) Add ZooKeeperRequestLatencyMs to KafkaZkClient

[ https://issues.apache.org/jira/browse/KAFKA-6065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-6065: --- Summary: Add ZooKeeperRequestLatencyMs to KafkaZkClient (was: Add zookeeper metrics to

[jira] [Commented] (KAFKA-6065) Add zookeeper metrics to ZookeeperClient as in KIP-188

[ https://issues.apache.org/jira/browse/KAFKA-6065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16281102#comment-16281102 ] ASF GitHub Bot commented on KAFKA-6065: --- Github user asfgit closed the pull request at:

[jira] [Commented] (KAFKA-6200) 00000000000000000015.timeindex: The process cannot access the file because it is being used by another process.

[ https://issues.apache.org/jira/browse/KAFKA-6200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16281072#comment-16281072 ] Peter Carpenter commented on KAFKA-6200: Seems to be related to KAFKA-6075 >

[jira] [Commented] (KAFKA-6075) Kafka cannot recover after an unclean shutdown on Windows

[ https://issues.apache.org/jira/browse/KAFKA-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16281066#comment-16281066 ] Peter Carpenter commented on KAFKA-6075: On futher examination, deleting ALL index and timeindex

[jira] [Updated] (KAFKA-6322) Error deleting log for topic, all log dirs failed.

[ https://issues.apache.org/jira/browse/KAFKA-6322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dongyan li updated KAFKA-6322: -- Description: Hello, I encountered a error when I try to delete a topic with kafka version 1.0.0, the

[jira] [Created] (KAFKA-6322) Error deleting log for topic, all log dirs failed.

dongyan li created KAFKA-6322: - Summary: Error deleting log for topic, all log dirs failed. Key: KAFKA-6322 URL: https://issues.apache.org/jira/browse/KAFKA-6322 Project: Kafka Issue Type: Bug

[jira] [Assigned] (KAFKA-6321) ConsumerGroupCommand should use the new consumer to query the log end offsets.

[ https://issues.apache.org/jira/browse/KAFKA-6321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian reassigned KAFKA-6321: -- Assignee: Vahid Hashemian > ConsumerGroupCommand should use the new consumer to query

[jira] [Created] (KAFKA-6321) ConsumerGroupCommand should use the new consumer to query the log end offsets.

Jiangjie Qin created KAFKA-6321: --- Summary: ConsumerGroupCommand should use the new consumer to query the log end offsets. Key: KAFKA-6321 URL: https://issues.apache.org/jira/browse/KAFKA-6321 Project:

[jira] [Commented] (KAFKA-6269) KTable state restore fails after rebalance

[ https://issues.apache.org/jira/browse/KAFKA-6269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16280993#comment-16280993 ] ASF GitHub Bot commented on KAFKA-6269: --- GitHub user bbejeck opened a pull request:

[jira] [Updated] (KAFKA-6319) kafka-acls regression for comma characters (and maybe other characters as well)

[ https://issues.apache.org/jira/browse/KAFKA-6319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-6319: --- Fix Version/s: 1.1.0 > kafka-acls regression for comma characters (and maybe other characters as >

[jira] [Updated] (KAFKA-6319) kafka-acls regression for comma characters (and maybe other characters as well)

[ https://issues.apache.org/jira/browse/KAFKA-6319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-6319: --- Labels: regression (was: ) > kafka-acls regression for comma characters (and maybe other characters

[jira] [Created] (KAFKA-6320) move ZK metrics in KafkaHealthCheck to ZookeeperClient

Jun Rao created KAFKA-6320: -- Summary: move ZK metrics in KafkaHealthCheck to ZookeeperClient Key: KAFKA-6320 URL: https://issues.apache.org/jira/browse/KAFKA-6320 Project: Kafka Issue Type:

[jira] [Updated] (KAFKA-6319) kafka-acls regression for comma characters (and maybe other characters as well)

[ https://issues.apache.org/jira/browse/KAFKA-6319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jordan Mcmillan updated KAFKA-6319: --- Description: As of version 1.0.0, kafka-acls.sh no longer recognizes my ACLs stored in

[jira] [Assigned] (KAFKA-6065) Add zookeeper metrics to ZookeeperClient as in KIP-188

[ https://issues.apache.org/jira/browse/KAFKA-6065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao reassigned KAFKA-6065: -- Assignee: Ismael Juma (was: Prasanna Gautam) > Add zookeeper metrics to ZookeeperClient as in KIP-188

[jira] [Created] (KAFKA-6319) kafka-acls regression for comma characters (and maybe other characters as well)

Jordan Mcmillan created KAFKA-6319: -- Summary: kafka-acls regression for comma characters (and maybe other characters as well) Key: KAFKA-6319 URL: https://issues.apache.org/jira/browse/KAFKA-6319

[jira] [Commented] (KAFKA-5882) NullPointerException in StreamTask

[ https://issues.apache.org/jira/browse/KAFKA-5882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16280918#comment-16280918 ] Matthias J. Sax commented on KAFKA-5882: I just looked into this a little bit. One side remark:

[jira] [Commented] (KAFKA-6298) Line numbers on log messages are incorrect

[ https://issues.apache.org/jira/browse/KAFKA-6298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16280878#comment-16280878 ] Narendra Kumar commented on KAFKA-6298: --- I would like to work on this, if nobody is working on this

[jira] [Commented] (KAFKA-6193) Only delete reassign_partitions znode after reassignment is complete

[ https://issues.apache.org/jira/browse/KAFKA-6193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16280852#comment-16280852 ] ASF GitHub Bot commented on KAFKA-6193: --- Github user asfgit closed the pull request at:

[jira] [Commented] (KAFKA-6059) Kafka cant delete old log files on windows

[ https://issues.apache.org/jira/browse/KAFKA-6059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16280804#comment-16280804 ] Rainer Guessner commented on KAFKA-6059: I have the same exception. I get the exception by

[jira] [Assigned] (KAFKA-6269) KTable state restore fails after rebalance

[ https://issues.apache.org/jira/browse/KAFKA-6269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-6269: -- Assignee: Bill Bejeck > KTable state restore fails after rebalance >

[jira] [Commented] (KAFKA-4767) KafkaProducer is not joining its IO thread properly

[ https://issues.apache.org/jira/browse/KAFKA-4767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16280793#comment-16280793 ] Matthias J. Sax commented on KAFKA-4767: Can we close this? Seems to be resolved via KAFKA-5936 ?

[jira] [Commented] (KAFKA-6300) SelectorTest may fail with ConcurrentModificationException

[ https://issues.apache.org/jira/browse/KAFKA-6300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16280783#comment-16280783 ] ASF GitHub Bot commented on KAFKA-6300: --- Github user asfgit closed the pull request at:

[jira] [Resolved] (KAFKA-6300) SelectorTest may fail with ConcurrentModificationException

[ https://issues.apache.org/jira/browse/KAFKA-6300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-6300. --- Resolution: Fixed Fix Version/s: 1.0.1 1.1.0 Issue resolved by pull

[jira] [Commented] (KAFKA-5520) Extend Consumer Group Reset Offset tool for Stream Applications

[ https://issues.apache.org/jira/browse/KAFKA-5520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16280777#comment-16280777 ] ASF GitHub Bot commented on KAFKA-5520: --- Github user asfgit closed the pull request at:

[jira] [Assigned] (KAFKA-5520) Extend Consumer Group Reset Offset tool for Stream Applications

[ https://issues.apache.org/jira/browse/KAFKA-5520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-5520: Assignee: Jorge Quilcate > Extend Consumer Group Reset Offset tool for Stream Applications

[jira] [Resolved] (KAFKA-5520) Extend Consumer Group Reset Offset tool for Stream Applications

[ https://issues.apache.org/jira/browse/KAFKA-5520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-5520. -- Resolution: Fixed Issue resolved by pull request 4159

[jira] [Created] (KAFKA-6318) StreamsResetter should return non-zero return code on error

Matthias J. Sax created KAFKA-6318: -- Summary: StreamsResetter should return non-zero return code on error Key: KAFKA-6318 URL: https://issues.apache.org/jira/browse/KAFKA-6318 Project: Kafka

[jira] [Commented] (KAFKA-6300) SelectorTest may fail with ConcurrentModificationException

[ https://issues.apache.org/jira/browse/KAFKA-6300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16280575#comment-16280575 ] ASF GitHub Bot commented on KAFKA-6300: --- Github user tedyu closed the pull request at:

[jira] [Commented] (KAFKA-6300) SelectorTest may fail with ConcurrentModificationException

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

[jira] [Assigned] (KAFKA-6313) Kafka Core maven dependencies are missing SLF4J API

[ https://issues.apache.org/jira/browse/KAFKA-6313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch reassigned KAFKA-6313: Assignee: Randall Hauch (was: Ismael Juma) > Kafka Core maven dependencies are missing

[jira] [Updated] (KAFKA-6199) Single broker with fast growing heap usage

[ https://issues.apache.org/jira/browse/KAFKA-6199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robin Tweedie updated KAFKA-6199: - Attachment: histo_live_20171206.txt Here is today's heap histogram as the broker got close to 75%

[jira] [Commented] (KAFKA-6317) Maven artifact for kafka should not depend on log4j

[ https://issues.apache.org/jira/browse/KAFKA-6317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16280505#comment-16280505 ] ASF GitHub Bot commented on KAFKA-6317: --- GitHub user ijuma opened a pull request:

[jira] [Created] (KAFKA-6317) Maven artifact for kafka should not depend on log4j

Ismael Juma created KAFKA-6317: -- Summary: Maven artifact for kafka should not depend on log4j Key: KAFKA-6317 URL: https://issues.apache.org/jira/browse/KAFKA-6317 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-5722) Refactor ConfigCommand to use the AdminClient

[ https://issues.apache.org/jira/browse/KAFKA-5722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16280473#comment-16280473 ] Viktor Somogyi commented on KAFKA-5722: --- [~rsivaram] yes, I'm planning to submit it. I'm not sure

[jira] [Updated] (KAFKA-6311) Expose Kafka cluster ID in Connect REST API

[ https://issues.apache.org/jira/browse/KAFKA-6311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-6311: - Labels: needs-kip (was: ) > Expose Kafka cluster ID in Connect REST API >

[jira] [Commented] (KAFKA-5722) Refactor ConfigCommand to use the AdminClient

[ https://issues.apache.org/jira/browse/KAFKA-5722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16280324#comment-16280324 ] Rajini Sivaram commented on KAFKA-5722: --- [~viktorsomogyi] Are you planning to submit a KIP for this?

[jira] [Commented] (KAFKA-6313) Kafka Core maven dependencies are missing SLF4J API

[ https://issues.apache.org/jira/browse/KAFKA-6313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16280289#comment-16280289 ] ASF GitHub Bot commented on KAFKA-6313: --- GitHub user rhauch opened a pull request:

[jira] [Comment Edited] (KAFKA-6313) Kafka Core maven dependencies are missing SLF4J API

[ https://issues.apache.org/jira/browse/KAFKA-6313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16280268#comment-16280268 ] Ismael Juma edited comment on KAFKA-6313 at 12/6/17 2:55 PM: - Interesting, so

[jira] [Updated] (KAFKA-6313) Kafka Core maven dependencies are missing SLF4J API

[ https://issues.apache.org/jira/browse/KAFKA-6313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-6313: --- Priority: Major (was: Minor) > Kafka Core maven dependencies are missing SLF4J API >

[jira] [Commented] (KAFKA-6313) Kafka Core maven dependencies are missing SLF4J API

[ https://issues.apache.org/jira/browse/KAFKA-6313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16280260#comment-16280260 ] Randall Hauch commented on KAFKA-6313: -- [~ijuma], you are correct that other dependencies in my

[jira] [Resolved] (KAFKA-6174) Add methods in Options classes to keep binary compatibility with 0.11

[ https://issues.apache.org/jira/browse/KAFKA-6174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-6174. Resolution: Fixed Fix Version/s: 1.1.0 > Add methods in Options classes to keep binary

[jira] [Commented] (KAFKA-6174) Add methods in Options classes to keep binary compatibility with 0.11

[ https://issues.apache.org/jira/browse/KAFKA-6174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16280211#comment-16280211 ] ASF GitHub Bot commented on KAFKA-6174: --- Github user asfgit closed the pull request at:

[jira] [Created] (KAFKA-6316) Kafka Rebalancing issues when I kill one consumer

Krishan created KAFKA-6316: -- Summary: Kafka Rebalancing issues when I kill one consumer Key: KAFKA-6316 URL: https://issues.apache.org/jira/browse/KAFKA-6316 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-6315) kafka-console-consumer.sh terminating consumer process only for one partition with java.lang.IllegalArgumentException: Unknown compression type id: 5

VinayKumar created KAFKA-6315: - Summary: kafka-console-consumer.sh terminating consumer process only for one partition with java.lang.IllegalArgumentException: Unknown compression type id: 5 Key: KAFKA-6315 URL:

[jira] [Created] (KAFKA-6314) Add a tool to delete consumer offsets for a given group

Tom Scott created KAFKA-6314: Summary: Add a tool to delete consumer offsets for a given group Key: KAFKA-6314 URL: https://issues.apache.org/jira/browse/KAFKA-6314 Project: Kafka Issue Type:

[jira] [Assigned] (KAFKA-6313) Kafka Core maven dependencies are missing SLF4J API

[ https://issues.apache.org/jira/browse/KAFKA-6313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma reassigned KAFKA-6313: -- Assignee: Ismael Juma > Kafka Core maven dependencies are missing SLF4J API >

[jira] [Commented] (KAFKA-6313) Kafka Core maven dependencies are missing SLF4J API

[ https://issues.apache.org/jira/browse/KAFKA-6313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16279805#comment-16279805 ] Ismael Juma commented on KAFKA-6313: slf4j-api is a dependency of slf4j-log4j12: