[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=16553650#comment-16553650 ] ASF GitHub Bot commented on KAFKA-7195: --- omkreddy opened a new pull request #5418: KAFKA-7195: Fix

[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=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=16553496#comment-16553496 ] Vahid Hashemian edited comment on KAFKA-7044 at 7/23/18 11:57 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=16553542#comment-16553542 ] Matthias J. Sax commented on KAFKA-7175: I guess that would be ok – personally, I would keep it

[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=16553531#comment-16553531 ] ASF GitHub Bot commented on KAFKA-7194: --- hachikuji opened a new pull request #5417: KAFKA-7194; Fix

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

[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=16553499#comment-16553499 ] Guozhang Wang commented on KAFKA-7158: -- Hi Christian, I've tried the above example code on both 1.1

[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=16553501#comment-16553501 ] ASF GitHub Bot commented on KAFKA-2423: --- TolerableCoder opened a new pull request #5416:

[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

[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=16553496#comment-16553496 ] Vahid Hashemian commented on KAFKA-7044: [~ejpearson], thanks for providing the additional info.

[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=16553405#comment-16553405 ] Ray Chiang commented on KAFKA-7175: --- One common way to do this is to have python run a small Java

[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=16553212#comment-16553212 ] Manikumar commented on KAFKA-6438: -- This might have been fixed in KAFKA-6630 cleanups.  > NSEE while

[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=16553210#comment-16553210 ] Christian Henry commented on KAFKA-7158: I don't think we explicitly set the cache size, so

[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

[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=16553191#comment-16553191 ] ASF GitHub Bot commented on KAFKA-7193: --- rajinisivaram closed pull request #5414: KAFKA-7193: Use

[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=16553170#comment-16553170 ] Guozhang Wang commented on KAFKA-7158: -- I tried the following test on 1.1 branch, is that

[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

[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=16553161#comment-16553161 ] Christian Henry commented on KAFKA-7158: Sure, our store builder we're providing to Kaka Streams

[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=16553153#comment-16553153 ] Guozhang Wang commented on KAFKA-7158: -- Hello [~cah6] I'm trying to reproduce your observed issue

[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=16553134#comment-16553134 ] Guozhang Wang commented on KAFKA-7190: -- Hello [~lambdaliu], before you start picking up this ticket,

[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=16553124#comment-16553124 ] Guozhang Wang commented on KAFKA-6520: -- [~milindjain] I'm not very familiar about stormKafka, maybe

[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=16553095#comment-16553095 ] Matthias J. Sax commented on KAFKA-7190: Thanks for picking this up [~lambdaliu]. I would like

[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=16552946#comment-16552946 ] ASF GitHub Bot commented on KAFKA-7134: --- akatona84 opened a new pull request #5415: KAFKA-7134:

[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

[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=16552922#comment-16552922 ] Rajini Sivaram commented on KAFKA-7193: --- Created

[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=16552795#comment-16552795 ] ASF GitHub Bot commented on KAFKA-7193: --- rajinisivaram opened a new pull request #5414: KAFKA-7193:

[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=16552696#comment-16552696 ] Nayana Thorat commented on KAFKA-6918: -- Thanks for info. Will check in tag 1.1.1 This issue can be

[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

[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=16552623#comment-16552623 ] niulongfei commented on KAFKA-6240: --- bin/kafka-configs.sh --bootstrap-server

[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