[jira] [Commented] (KAFKA-7078) Kafka 1.0.1 Broker version crashes when deleting log

[ https://issues.apache.org/jira/browse/KAFKA-7078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16553864#comment-16553864 ] xiaojing zhou commented on KAFKA-7078: -- !image-2018-07-24-14-23-19-183.png! > Kafka

[jira] [Updated] (KAFKA-7078) Kafka 1.0.1 Broker version crashes when deleting log

[ https://issues.apache.org/jira/browse/KAFKA-7078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaojing zhou updated KAFKA-7078: - Attachment: image-2018-07-24-14-23-19-183.png > Kafka 1.0.1 Broker version crashes when deleting

[jira] [Comment Edited] (KAFKA-7078) Kafka 1.0.1 Broker version crashes when deleting log

[ https://issues.apache.org/jira/browse/KAFKA-7078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16553861#comment-16553861 ] xiaojing zhou edited comment on KAFKA-7078 at 7/24/18 6:22 AM:

[jira] [Commented] (KAFKA-7078) Kafka 1.0.1 Broker version crashes when deleting log

[ https://issues.apache.org/jira/browse/KAFKA-7078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16553861#comment-16553861 ] xiaojing zhou commented on KAFKA-7078: -- !screenshot-1.png! The weird thing is that,

[jira] [Commented] (KAFKA-7195) StreamStreamJoinIntegrationTest fails in 2.0 Jenkins

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

[jira] [Comment Edited] (KAFKA-7044) kafka-consumer-groups.sh NullPointerException describing round robin or sticky assignors

[ https://issues.apache.org/jira/browse/KAFKA-7044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16553496#comment-16553496 ] Vahid Hashemian edited comment on KAFKA-7044 at 7/23/18 11:58 PM: -

[jira] [Comment Edited] (KAFKA-7044) kafka-consumer-groups.sh NullPointerException describing round robin or sticky assignors

[ https://issues.apache.org/jira/browse/KAFKA-7044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16553496#comment-16553496 ] Vahid Hashemian edited comment on KAFKA-7044 at 7/23/18 11:57 PM: -

[jira] [Comment Edited] (KAFKA-7044) kafka-consumer-groups.sh NullPointerException describing round robin or sticky assignors

[ https://issues.apache.org/jira/browse/KAFKA-7044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16553496#comment-16553496 ] Vahid Hashemian edited comment on KAFKA-7044 at 7/23/18 11:33 PM: -

[jira] [Commented] (KAFKA-7175) Make version checking logic more flexible in streams_upgrade_test.py

[ https://issues.apache.org/jira/browse/KAFKA-7175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16553542#comment-16553542 ] Matthias J. Sax commented on KAFKA-7175: I guess that would be ok – personally, I

[jira] [Commented] (KAFKA-7194) Error deserializing assignment after rebalance

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

[jira] [Updated] (KAFKA-7196) Remove heartbeat delayed operation for those removed consumers at the end of each rebalance

[ https://issues.apache.org/jira/browse/KAFKA-7196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7196: Fix Version/s: 2.1.0 > Remove heartbeat delayed operation for those removed consumers at the end of > each

[jira] [Assigned] (KAFKA-7196) Remove heartbeat delayed operation for those removed consumers at the end of each rebalance

[ https://issues.apache.org/jira/browse/KAFKA-7196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin reassigned KAFKA-7196: --- Assignee: Lincong Li > Remove heartbeat delayed operation for those removed consumers at the end of

[jira] [Commented] (KAFKA-7158) Duplicates when searching kafka stream state store with caching

[ https://issues.apache.org/jira/browse/KAFKA-7158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16553499#comment-16553499 ] Guozhang Wang commented on KAFKA-7158: -- Hi Christian, I've tried the above example c

[jira] [Commented] (KAFKA-2423) Expand scalafmt coverage to core

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

[jira] [Created] (KAFKA-7196) Remove heartbeat delayed operation for those removed consumers at the end of each rebalance

Lincong Li created KAFKA-7196: - Summary: Remove heartbeat delayed operation for those removed consumers at the end of each rebalance Key: KAFKA-7196 URL: https://issues.apache.org/jira/browse/KAFKA-7196 P

[jira] [Commented] (KAFKA-2423) Expand scalafmt coverage to core

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

[jira] [Commented] (KAFKA-7044) kafka-consumer-groups.sh NullPointerException describing round robin or sticky assignors

[ https://issues.apache.org/jira/browse/KAFKA-7044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16553496#comment-16553496 ] Vahid Hashemian commented on KAFKA-7044: [~ejpearson], thanks for providing the a

[jira] [Created] (KAFKA-7195) StreamStreamJoinIntegrationTest fails in 2.0 Jenkins

Ted Yu created KAFKA-7195: - Summary: StreamStreamJoinIntegrationTest fails in 2.0 Jenkins Key: KAFKA-7195 URL: https://issues.apache.org/jira/browse/KAFKA-7195 Project: Kafka Issue Type: Test

[jira] [Commented] (KAFKA-7175) Make version checking logic more flexible in streams_upgrade_test.py

[ https://issues.apache.org/jira/browse/KAFKA-7175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16553405#comment-16553405 ] Ray Chiang commented on KAFKA-7175: --- One common way to do this is to have python run a

[jira] [Updated] (KAFKA-6929) ZkData - Consumers offsets Zookeeper path is not correct

[ https://issues.apache.org/jira/browse/KAFKA-6929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-6929: --- Fix Version/s: 1.1.1 > ZkData - Consumers offsets Zookeeper path is not correct > ---

[jira] [Commented] (KAFKA-6438) NSEE while concurrently creating and deleting a topic

[ https://issues.apache.org/jira/browse/KAFKA-6438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16553212#comment-16553212 ] Manikumar commented on KAFKA-6438: -- This might have been fixed in KAFKA-6630 cleanups. 

[jira] [Commented] (KAFKA-7158) Duplicates when searching kafka stream state store with caching

[ https://issues.apache.org/jira/browse/KAFKA-7158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16553210#comment-16553210 ] Christian Henry commented on KAFKA-7158: I don't think we explicitly set the cach

[jira] [Resolved] (KAFKA-7193) ZooKeeper client times out with localhost due to random choice of ipv4/ipv6

[ https://issues.apache.org/jira/browse/KAFKA-7193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-7193. --- Resolution: Fixed Reviewer: Ismael Juma Fix Version/s: 2.0.0 > ZooKeeper clie

[jira] [Commented] (KAFKA-7193) ZooKeeper client times out with localhost due to random choice of ipv4/ipv6

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

[jira] [Commented] (KAFKA-7158) Duplicates when searching kafka stream state store with caching

[ https://issues.apache.org/jira/browse/KAFKA-7158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16553171#comment-16553171 ] Guozhang Wang commented on KAFKA-7158: -- How large is your cache size? Actually, if y

[jira] [Commented] (KAFKA-7158) Duplicates when searching kafka stream state store with caching

[ https://issues.apache.org/jira/browse/KAFKA-7158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16553170#comment-16553170 ] Guozhang Wang commented on KAFKA-7158: -- I tried the following test on 1.1 branch, is

[jira] [Resolved] (KAFKA-6918) Kafka server fails to start with IBM JAVA

[ https://issues.apache.org/jira/browse/KAFKA-6918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang resolved KAFKA-6918. --- Resolution: Fixed Fix Version/s: 1.1.1 > Kafka server fails to start with IBM JAVA > -

[jira] [Updated] (KAFKA-2423) Expand scalafmt coverage to core

[ https://issues.apache.org/jira/browse/KAFKA-2423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-2423: -- Summary: Expand scalafmt coverage to core (was: Introduce Scalastyle) > Expand scalafmt coverage to co

[jira] [Commented] (KAFKA-7158) Duplicates when searching kafka stream state store with caching

[ https://issues.apache.org/jira/browse/KAFKA-7158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16553161#comment-16553161 ] Christian Henry commented on KAFKA-7158: Sure, our store builder we're providing

[jira] [Created] (KAFKA-7194) Error deserializing assignment after rebalance

Konstantine Karantasis created KAFKA-7194: - Summary: Error deserializing assignment after rebalance Key: KAFKA-7194 URL: https://issues.apache.org/jira/browse/KAFKA-7194 Project: Kafka

[jira] [Commented] (KAFKA-7158) Duplicates when searching kafka stream state store with caching

[ https://issues.apache.org/jira/browse/KAFKA-7158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16553153#comment-16553153 ] Guozhang Wang commented on KAFKA-7158: -- Hello [~cah6] I'm trying to reproduce your o

[jira] [Commented] (KAFKA-7190) Under low traffic conditions purging repartition topics cause WARN statements about UNKNOWN_PRODUCER_ID

[ https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16553134#comment-16553134 ] Guozhang Wang commented on KAFKA-7190: -- Hello [~lambdaliu], before you start picking

[jira] [Commented] (KAFKA-6520) When a Kafka Stream can't communicate with the server, it's Status stays RUNNING

[ https://issues.apache.org/jira/browse/KAFKA-6520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16553124#comment-16553124 ] Guozhang Wang commented on KAFKA-6520: -- [~milindjain] I'm not very familiar about st

[jira] [Updated] (KAFKA-6809) connections-created metric does not behave as expected

[ https://issues.apache.org/jira/browse/KAFKA-6809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram updated KAFKA-6809: -- Fix Version/s: (was: 1.1.1) > connections-created metric does not behave as expected >

[jira] [Commented] (KAFKA-7190) Under low traffic conditions purging repartition topics cause WARN statements about UNKNOWN_PRODUCER_ID

[ https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16553095#comment-16553095 ] Matthias J. Sax commented on KAFKA-7190: Thanks for picking this up [~lambdaliu].

[jira] [Commented] (KAFKA-7134) KafkaLog4jAppender - Appender exceptions are propagated to caller

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

[jira] [Updated] (KAFKA-7121) Intermittently, Connectors fail to assign tasks and keep retrying every second forever.

[ https://issues.apache.org/jira/browse/KAFKA-7121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-7121: - Affects Version/s: 1.1.0 > Intermittently, Connectors fail to assign tasks and keep retrying ever

[jira] [Commented] (KAFKA-7193) ZooKeeper client times out with localhost due to random choice of ipv4/ipv6

[ https://issues.apache.org/jira/browse/KAFKA-7193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16552922#comment-16552922 ] Rajini Sivaram commented on KAFKA-7193: --- Created https://issues.apache.org/jira/bro

[jira] [Commented] (KAFKA-7193) ZooKeeper client times out with localhost due to random choice of ipv4/ipv6

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

[jira] [Created] (KAFKA-7193) ZooKeeper client times out with localhost due to random choice of ipv4/ipv6

Rajini Sivaram created KAFKA-7193: - Summary: ZooKeeper client times out with localhost due to random choice of ipv4/ipv6 Key: KAFKA-7193 URL: https://issues.apache.org/jira/browse/KAFKA-7193 Project:

[jira] [Commented] (KAFKA-6918) Kafka server fails to start with IBM JAVA

[ https://issues.apache.org/jira/browse/KAFKA-6918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16552696#comment-16552696 ] Nayana Thorat commented on KAFKA-6918: -- Thanks for info. Will check in tag 1.1.1 Th

[jira] [Assigned] (KAFKA-7190) Under low traffic conditions purging repartition topics cause WARN statements about UNKNOWN_PRODUCER_ID

[ https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lambdaliu reassigned KAFKA-7190: Assignee: lambdaliu > Under low traffic conditions purging repartition topics cause WARN statement

[jira] [Commented] (KAFKA-6240) Support dynamic updates of frequently updated broker configs

[ https://issues.apache.org/jira/browse/KAFKA-6240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16552623#comment-16552623 ] niulongfei commented on KAFKA-6240: --- bin/kafka-configs.sh --bootstrap-server node10.hc

[jira] [Created] (KAFKA-7192) State-store can desynchronise with changelog

Jon Bates created KAFKA-7192: Summary: State-store can desynchronise with changelog Key: KAFKA-7192 URL: https://issues.apache.org/jira/browse/KAFKA-7192 Project: Kafka Issue Type: Bug

[jira] [Updated] (KAFKA-7192) State-store can desynchronise with changelog

[ https://issues.apache.org/jira/browse/KAFKA-7192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jon Bates updated KAFKA-7192: - Description: n.b. this bug has been verified with exactly-once processing enabled Consider the following