[jira] [Commented] (KAFKA-6711) GlobalStateManagerImpl should not write offsets of in-memory stores in checkpoint file

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

[jira] [Commented] (KAFKA-6711) GlobalStateManagerImpl should not write offsets of in-memory stores in checkpoint file

[ https://issues.apache.org/jira/browse/KAFKA-6711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16416847#comment-16416847 ] ASF GitHub Bot commented on KAFKA-6711: --- cemo closed pull request #4782: KAFKA-6711:

[jira] [Commented] (KAFKA-6723) Separate "max.poll.record" for restore consumer and common consumer

[ https://issues.apache.org/jira/browse/KAFKA-6723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16416816#comment-16416816 ] Guozhang Wang commented on KAFKA-6723: -- What are the driving rationales for different default values

[jira] [Updated] (KAFKA-6642) Rack aware task assignment in kafka streams

[ https://issues.apache.org/jira/browse/KAFKA-6642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish Surana updated KAFKA-6642: - Summary: Rack aware task assignment in kafka streams (was: Rack aware replica assignment in

[jira] [Commented] (KAFKA-6723) Separate "max.poll.record" for restore consumer and common consumer

[ https://issues.apache.org/jira/browse/KAFKA-6723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16416806#comment-16416806 ] Matthias J. Sax commented on KAFKA-6723: Make sense to me. Seems to be related to KAFKA-6657 -- do

[jira] [Comment Edited] (KAFKA-6642) Rack aware replica assignment in kafka streams

[ https://issues.apache.org/jira/browse/KAFKA-6642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16416778#comment-16416778 ] Ashish Surana edited comment on KAFKA-6642 at 3/28/18 4:18 AM: --- Current task

[jira] [Comment Edited] (KAFKA-6642) Rack aware replica assignment in kafka streams

[ https://issues.apache.org/jira/browse/KAFKA-6642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16416778#comment-16416778 ] Ashish Surana edited comment on KAFKA-6642 at 3/28/18 4:13 AM: --- Current task

[jira] [Comment Edited] (KAFKA-6642) Rack aware replica assignment in kafka streams

[ https://issues.apache.org/jira/browse/KAFKA-6642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16416778#comment-16416778 ] Ashish Surana edited comment on KAFKA-6642 at 3/28/18 4:12 AM: --- Current task

[jira] [Commented] (KAFKA-6642) Rack aware replica assignment in kafka streams

[ https://issues.apache.org/jira/browse/KAFKA-6642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16416778#comment-16416778 ] Ashish Surana commented on KAFKA-6642: -- Current task assignor is sticky, and it can be made

[jira] [Commented] (KAFKA-6723) Separate "max.poll.record" for restore consumer and common consumer

[ https://issues.apache.org/jira/browse/KAFKA-6723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16416749#comment-16416749 ] Boyang Chen commented on KAFKA-6723: [~guozhang] [~liquanpei] [~mjsax] Thoughts on this? > Separate

[jira] [Created] (KAFKA-6723) Separate "max.poll.record" for restore consumer and common consumer

Boyang Chen created KAFKA-6723: -- Summary: Separate "max.poll.record" for restore consumer and common consumer Key: KAFKA-6723 URL: https://issues.apache.org/jira/browse/KAFKA-6723 Project: Kafka

[jira] [Updated] (KAFKA-6473) Add MockProcessorContext to public test-utils

[ https://issues.apache.org/jira/browse/KAFKA-6473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6473: --- Labels: kip user-experience (was: needs-kip user-experience) > Add MockProcessorContext to

[jira] [Comment Edited] (KAFKA-6649) ReplicaFetcher stopped after non fatal exception is thrown

[ https://issues.apache.org/jira/browse/KAFKA-6649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16416382#comment-16416382 ] Srinivas Dhruvakumar edited comment on KAFKA-6649 at 3/28/18 2:31 AM: --

[jira] [Commented] (KAFKA-6417) plugin.path pointing at a plugin directory causes ClassNotFoundException

[ https://issues.apache.org/jira/browse/KAFKA-6417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16416542#comment-16416542 ] Dustin Cote commented on KAFKA-6417: I think catching the exception and suggesting an action to

[jira] [Updated] (KAFKA-6722) SensorAccess.getOrCreate should be more efficient

[ https://issues.apache.org/jira/browse/KAFKA-6722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wade wu updated KAFKA-6722: --- Description: The lock/unlock of read lock in getOrCreate() is not necessary, or it should be refactored. For

[jira] [Created] (KAFKA-6722) SensorAccess.getOrCreate should be more efficient

wade wu created KAFKA-6722: -- Summary: SensorAccess.getOrCreate should be more efficient Key: KAFKA-6722 URL: https://issues.apache.org/jira/browse/KAFKA-6722 Project: Kafka Issue Type: Improvement

[jira] [Comment Edited] (KAFKA-6417) plugin.path pointing at a plugin directory causes ClassNotFoundException

[ https://issues.apache.org/jira/browse/KAFKA-6417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16416438#comment-16416438 ] Chris Egerton edited comment on KAFKA-6417 at 3/28/18 12:14 AM: [~cotedm]

[jira] [Commented] (KAFKA-6437) Streams does not warn about missing input topics, but hangs

[ https://issues.apache.org/jira/browse/KAFKA-6437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16416494#comment-16416494 ] Guozhang Wang commented on KAFKA-6437: -- This is a interesting reported issue in KAFKA-6720 that for

[jira] [Closed] (KAFKA-6473) Add MockProcessorContext to public test-utils

[ https://issues.apache.org/jira/browse/KAFKA-6473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler closed KAFKA-6473. --- The PR for this work is merged: https://github.com/apache/kafka/pull/4736 > Add MockProcessorContext to

[jira] [Commented] (KAFKA-6386) Deprecate KafkaStreams constructor taking StreamsConfig parameter

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

[jira] [Commented] (KAFKA-6417) plugin.path pointing at a plugin directory causes ClassNotFoundException

[ https://issues.apache.org/jira/browse/KAFKA-6417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16416438#comment-16416438 ] Chris Egerton commented on KAFKA-6417: -- Alright, given that insight I agree that issuing warnings for

[jira] [Created] (KAFKA-6721) Consolidate state store management for global stores and normal stores

Guozhang Wang created KAFKA-6721: Summary: Consolidate state store management for global stores and normal stores Key: KAFKA-6721 URL: https://issues.apache.org/jira/browse/KAFKA-6721 Project: Kafka

[jira] [Assigned] (KAFKA-6716) discardChannel should be released in MockSelector#completeSend

[ https://issues.apache.org/jira/browse/KAFKA-6716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx reassigned KAFKA-6716: - Assignee: huxihx > discardChannel should be released in MockSelector#completeSend >

[jira] [Commented] (KAFKA-6716) discardChannel should be released in MockSelector#completeSend

[ https://issues.apache.org/jira/browse/KAFKA-6716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16416428#comment-16416428 ] ASF GitHub Bot commented on KAFKA-6716: --- huxihx opened a new pull request #4783: KAFKA-6716: Should

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

[ https://issues.apache.org/jira/browse/KAFKA-5882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16416425#comment-16416425 ] Matthias J. Sax commented on KAFKA-5882: Thanks for reporting this. Can you upgrade to 0.11.0.2 or

[jira] [Commented] (KAFKA-6649) ReplicaFetcher stopped after non fatal exception is thrown

[ https://issues.apache.org/jira/browse/KAFKA-6649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16416382#comment-16416382 ] Srinivas Dhruvakumar commented on KAFKA-6649: - I am trying out the patch "high watermark could

[jira] [Resolved] (KAFKA-6720) Inconsistent Kafka Streams behaviour when topic does not exist

[ https://issues.apache.org/jira/browse/KAFKA-6720?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mariam John resolved KAFKA-6720. Resolution: Duplicate This is similar to KAFKA-6437. > Inconsistent Kafka Streams behaviour when

[jira] [Created] (KAFKA-6720) Inconsistent Kafka Streams behaviour when topic does not exist

Daniel Wojda created KAFKA-6720: --- Summary: Inconsistent Kafka Streams behaviour when topic does not exist Key: KAFKA-6720 URL: https://issues.apache.org/jira/browse/KAFKA-6720 Project: Kafka

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

[ https://issues.apache.org/jira/browse/KAFKA-5882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16416281#comment-16416281 ] Vikas Tikoo commented on KAFKA-5882: We have encountered this issue 19 times in the last 15 days, and

[jira] [Resolved] (KAFKA-6473) Add MockProcessorContext to public test-utils

[ https://issues.apache.org/jira/browse/KAFKA-6473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6473. Resolution: Fixed Fix Version/s: 1.2.0 > Add MockProcessorContext to public

[jira] [Commented] (KAFKA-6473) Add MockProcessorContext to public test-utils

[ https://issues.apache.org/jira/browse/KAFKA-6473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16416246#comment-16416246 ] ASF GitHub Bot commented on KAFKA-6473: --- mjsax closed pull request #4736: KAFKA-6473: Add

[jira] [Commented] (KAFKA-6417) plugin.path pointing at a plugin directory causes ClassNotFoundException

[ https://issues.apache.org/jira/browse/KAFKA-6417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16416232#comment-16416232 ] Dustin Cote commented on KAFKA-6417: [~ChrisEgerton] yeah it's a bit extreme probably to kill the

[jira] [Commented] (KAFKA-6417) plugin.path pointing at a plugin directory causes ClassNotFoundException

[ https://issues.apache.org/jira/browse/KAFKA-6417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16416201#comment-16416201 ] Chris Egerton commented on KAFKA-6417: -- Curious--why do you think false positives would be a big

[jira] [Comment Edited] (KAFKA-6417) plugin.path pointing at a plugin directory causes ClassNotFoundException

[ https://issues.apache.org/jira/browse/KAFKA-6417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16416174#comment-16416174 ] Chris Egerton edited comment on KAFKA-6417 at 3/27/18 8:18 PM: --- Sorry,

[jira] [Commented] (KAFKA-6417) plugin.path pointing at a plugin directory causes ClassNotFoundException

[ https://issues.apache.org/jira/browse/KAFKA-6417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16416174#comment-16416174 ] Chris Egerton commented on KAFKA-6417: -- There's also the case where a plugin performs some operations

[jira] [Commented] (KAFKA-6711) GlobalStateManagerImpl should not write offsets of in-memory stores in checkpoint file

[ https://issues.apache.org/jira/browse/KAFKA-6711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16416168#comment-16416168 ] Cemalettin Koç commented on KAFKA-6711: --- Sorry to open quickly issue :( Bot polluted issue.  Here

[jira] [Commented] (KAFKA-6711) GlobalStateManagerImpl should not write offsets of in-memory stores in checkpoint file

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

[jira] [Commented] (KAFKA-6417) plugin.path pointing at a plugin directory causes ClassNotFoundException

[ https://issues.apache.org/jira/browse/KAFKA-6417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16416143#comment-16416143 ] Dustin Cote commented on KAFKA-6417: [~ChrisEgerton] I think the problem with this is that in practice

[jira] [Resolved] (KAFKA-6719) Kafka Reassign Partitions Failure

[ https://issues.apache.org/jira/browse/KAFKA-6719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Srinivas Dhruvakumar resolved KAFKA-6719. - Resolution: Invalid > Kafka Reassign Partitions Failure >

[jira] [Created] (KAFKA-6719) Kafka Reassign Partitions Failure

Srinivas Dhruvakumar created KAFKA-6719: --- Summary: Kafka Reassign Partitions Failure Key: KAFKA-6719 URL: https://issues.apache.org/jira/browse/KAFKA-6719 Project: Kafka Issue Type:

[jira] [Updated] (KAFKA-6718) Rack Aware Replica Task Assignment for Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-6718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6718: --- Labels: needs-kip (was: ) > Rack Aware Replica Task Assignment for Kafka Streams >

[jira] [Updated] (KAFKA-6127) Streams should never block infinitely

[ https://issues.apache.org/jira/browse/KAFKA-6127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6127: --- Labels: exactly-once (was: ) > Streams should never block infinitely >

[jira] [Updated] (KAFKA-6446) KafkaProducer with transactionId endless waits when bootstrap server is down

[ https://issues.apache.org/jira/browse/KAFKA-6446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6446: --- Labels: exactly-once (was: ) > KafkaProducer with transactionId endless waits when bootstrap

[jira] [Updated] (KAFKA-6127) Streams should never block infinitely

[ https://issues.apache.org/jira/browse/KAFKA-6127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6127: --- Description: Streams uses three consumer APIs that can block infinite: {{commitSync()}},

[jira] [Commented] (KAFKA-6718) Rack Aware Replica Task Assignment for Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-6718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16415967#comment-16415967 ] Guozhang Wang commented on KAFKA-6718: -- [~_deepakgoyal] thanks for creating the KIP! I've assigned

[jira] [Assigned] (KAFKA-6718) Rack Aware Replica Task Assignment for Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-6718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-6718: Assignee: Deepak Goyal > Rack Aware Replica Task Assignment for Kafka Streams >

[jira] [Commented] (KAFKA-6417) plugin.path pointing at a plugin directory causes ClassNotFoundException

[ https://issues.apache.org/jira/browse/KAFKA-6417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16415952#comment-16415952 ] Chris Egerton commented on KAFKA-6417: -- Just detecting a JAR file on a {{plugin.path}} directory

[jira] [Assigned] (KAFKA-5540) Deprecate and remove internal converter configs

[ https://issues.apache.org/jira/browse/KAFKA-5540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton reassigned KAFKA-5540: Assignee: Chris Egerton > Deprecate and remove internal converter configs >

[jira] [Updated] (KAFKA-5540) Deprecate and remove internal converter configs

[ https://issues.apache.org/jira/browse/KAFKA-5540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-5540: - Fix Version/s: 1.2.0 > Deprecate and remove internal converter configs >

[jira] [Commented] (KAFKA-6446) KafkaProducer with transactionId endless waits when bootstrap server is down

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

[jira] [Resolved] (KAFKA-6446) KafkaProducer with transactionId endless waits when bootstrap server is down

[ https://issues.apache.org/jira/browse/KAFKA-6446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6446. Resolution: Fixed Fix Version/s: 1.2.0 > KafkaProducer with transactionId endless

[jira] [Comment Edited] (KAFKA-6698) ConsumerBounceTest#testClose sometimes fails

[ https://issues.apache.org/jira/browse/KAFKA-6698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16407577#comment-16407577 ] Ted Yu edited comment on KAFKA-6698 at 3/27/18 3:17 PM: Test output consisted of

[jira] [Updated] (KAFKA-6718) Rack Aware Replica Task Assignment for Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-6718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Deepak Goyal updated KAFKA-6718: Description: |Machines in data centre are sometimes grouped in racks. Racks provide isolation as

[jira] [Updated] (KAFKA-6718) Rack Aware Replica Task Assignment for Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-6718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Deepak Goyal updated KAFKA-6718: Description: |Machines in data centre are sometimes grouped in racks. Racks provide isolation as

[jira] [Updated] (KAFKA-6718) Rack Aware Replica Task Assignment for Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-6718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Deepak Goyal updated KAFKA-6718: Description: |Machines in data centre are sometimes grouped in racks. Racks provide isolation as

[jira] [Created] (KAFKA-6718) Rack Aware Replica Task Assignment for Kafka Streams

Deepak Goyal created KAFKA-6718: --- Summary: Rack Aware Replica Task Assignment for Kafka Streams Key: KAFKA-6718 URL: https://issues.apache.org/jira/browse/KAFKA-6718 Project: Kafka Issue Type:

[jira] [Updated] (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:all-tabpanel ] Yuancheng PENG updated KAFKA-6717: -- Summary: TopicPartition Assined twice to a consumer group for 2 consumer instances (was:

[jira] [Comment Edited] (KAFKA-6711) GlobalStateManagerImpl should not write offsets of in-memory stores in checkpoint file

[ https://issues.apache.org/jira/browse/KAFKA-6711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16414673#comment-16414673 ] Cemalettin Koç edited comment on KAFKA-6711 at 3/27/18 7:13 AM: