[jira] [Commented] (KAFKA-7310) Fix SSL tests when running with Java 11

2018-08-23 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16591177#comment-16591177 ] Ismael Juma commented on KAFKA-7310: JDK 11 RC 1 includes the fix for JDK-8207317 and it fixes a

[jira] [Commented] (KAFKA-7335) Store clusterId locally to ensure broker joins the right cluster

2018-08-23 Thread Badai Aqrandista (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16591030#comment-16591030 ] Badai Aqrandista commented on KAFKA-7335: - Can we have this manually configured as well in

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

2018-08-23 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16590995#comment-16590995 ] Matthias J. Sax commented on KAFKA-6711: Upgrading KafkaStreams to 1.1.1 should be sufficient to

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

2018-08-23 Thread Naveen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16590885#comment-16590885 ] Naveen commented on KAFKA-6711: --- hello there We have developed a kafka-streams application using Kafka

[jira] [Created] (KAFKA-7335) Store clusterId locally to ensure broker joins the right cluster

2018-08-23 Thread Jason Gustafson (JIRA)
Jason Gustafson created KAFKA-7335: -- Summary: Store clusterId locally to ensure broker joins the right cluster Key: KAFKA-7335 URL: https://issues.apache.org/jira/browse/KAFKA-7335 Project: Kafka

[jira] [Commented] (KAFKA-6108) Synchronizing on commits and StandbyTasks can be improved

2018-08-23 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16590827#comment-16590827 ] Matthias J. Sax commented on KAFKA-6108: It's year back since I create this ticket and I guess

[jira] [Commented] (KAFKA-7225) Kafka Connect ConfigProvider not invoked before validation

2018-08-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16590826#comment-16590826 ] ASF GitHub Bot commented on KAFKA-7225: --- hachikuji closed pull request #5489: KAFKA-7225: Corrected

[jira] [Commented] (KAFKA-7333) Protocol changes for KIP-320

2018-08-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16590763#comment-16590763 ] ASF GitHub Bot commented on KAFKA-7333: --- hachikuji opened a new pull request #5564: KAFKA-7333;

[jira] [Updated] (KAFKA-7334) Suggest changing config for state.dir in case of FileNotFoundException

2018-08-23 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7334: --- Component/s: streams > Suggest changing config for state.dir in case of

[jira] [Commented] (KAFKA-5998) /.checkpoint.tmp Not found exception

2018-08-23 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16590729#comment-16590729 ] Ted Yu commented on KAFKA-5998: --- Logged KAFKA-7334 for improving exception message. The stack trace in the

[jira] [Created] (KAFKA-7334) Suggest changing config for state.dir in case of FileNotFoundException

2018-08-23 Thread Ted Yu (JIRA)
Ted Yu created KAFKA-7334: - Summary: Suggest changing config for state.dir in case of FileNotFoundException Key: KAFKA-7334 URL: https://issues.apache.org/jira/browse/KAFKA-7334 Project: Kafka

[jira] [Commented] (KAFKA-5066) KafkaMetricsConfig properties and description notably missing from documentation

2018-08-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16590719#comment-16590719 ] ASF GitHub Bot commented on KAFKA-5066: --- omkreddy opened a new pull request #5563: KAFKA-5066: Add

[jira] [Created] (KAFKA-7333) Protocol changes for KIP-320

2018-08-23 Thread Jason Gustafson (JIRA)
Jason Gustafson created KAFKA-7333: -- Summary: Protocol changes for KIP-320 Key: KAFKA-7333 URL: https://issues.apache.org/jira/browse/KAFKA-7333 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-7332) Improve error message when trying to produce message without key for compacted topic

2018-08-23 Thread Patrik Kleindl (JIRA)
Patrik Kleindl created KAFKA-7332: - Summary: Improve error message when trying to produce message without key for compacted topic Key: KAFKA-7332 URL: https://issues.apache.org/jira/browse/KAFKA-7332

[jira] [Commented] (KAFKA-6108) Synchronizing on commits and StandbyTasks can be improved

2018-08-23 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16590640#comment-16590640 ] Guozhang Wang commented on KAFKA-6108: -- [~mjsax] I was reading this ticket as part of KIP-353 since

[jira] [Assigned] (KAFKA-7040) The replica fetcher thread may truncate accepted messages during multiple fast leadership transitions

2018-08-23 Thread Lucas Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Wang reassigned KAFKA-7040: - Assignee: Lucas Wang > The replica fetcher thread may truncate accepted messages during

[jira] [Commented] (KAFKA-7040) The replica fetcher thread may truncate accepted messages during multiple fast leadership transitions

2018-08-23 Thread Lucas Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16590634#comment-16590634 ] Lucas Wang commented on KAFKA-7040: --- [~lindong] Sure, I will own this ticket and work on the fix. >

[jira] [Created] (KAFKA-7331) Kafka does not detect broker loss in the event of a network partition within the cluster

2018-08-23 Thread Kevin Li (JIRA)
Kevin Li created KAFKA-7331: --- Summary: Kafka does not detect broker loss in the event of a network partition within the cluster Key: KAFKA-7331 URL: https://issues.apache.org/jira/browse/KAFKA-7331

[jira] [Commented] (KAFKA-5998) /.checkpoint.tmp Not found exception

2018-08-23 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16590592#comment-16590592 ] Matthias J. Sax commented on KAFKA-5998: I guess we could check if the default `state.dir` is

[jira] [Commented] (KAFKA-7316) Use of filter method in KTable.scala may result in StackOverflowError

2018-08-23 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16590581#comment-16590581 ] Matthias J. Sax commented on KAFKA-7316: Meta question: it seems we hit multiple issues with

[jira] [Commented] (KAFKA-7040) The replica fetcher thread may truncate accepted messages during multiple fast leadership transitions

2018-08-23 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16590545#comment-16590545 ] Dong Lin commented on KAFKA-7040: - [~luwang] It looks like we need to fix this in Kafka to further reduce

[jira] [Commented] (KAFKA-5998) /.checkpoint.tmp Not found exception

2018-08-23 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16590547#comment-16590547 ] Ted Yu commented on KAFKA-5998: --- bq. java.nio.file.NoSuchFileException:

[jira] [Commented] (KAFKA-5998) /.checkpoint.tmp Not found exception

2018-08-23 Thread Ayushi (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16590505#comment-16590505 ] Ayushi commented on KAFKA-5998: ---  Great observation and advice. Will try it out. Thanks [~guozhang] >

[jira] [Commented] (KAFKA-5998) /.checkpoint.tmp Not found exception

2018-08-23 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16590492#comment-16590492 ] Guozhang Wang commented on KAFKA-5998: -- [~ayushi0430] One thing I actually missed, but your latest

[jira] [Resolved] (KAFKA-6309) add support for getting topic defaults from AdminClient

2018-08-23 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6309. -- Resolution: Fixed Closing as per above comment. We can use "describeConfigs(brokerResource, new

[jira] [Commented] (KAFKA-7314) MirrorMaker example in documentation does not work

2018-08-23 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16590472#comment-16590472 ] Manikumar commented on KAFKA-7314: -- As I mentioned above, this looks like Docker networking/DNS issue.

[jira] [Commented] (KAFKA-7316) Use of filter method in KTable.scala may result in StackOverflowError

2018-08-23 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16590456#comment-16590456 ] Guozhang Wang commented on KAFKA-7316: -- The PR needs to be rebased --- you can follow its status on

[jira] [Commented] (KAFKA-7316) Use of filter method in KTable.scala may result in StackOverflowError

2018-08-23 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16590450#comment-16590450 ] Ted Yu commented on KAFKA-7316: --- When would PR #5539 be merged ? > Use of filter method in KTable.scala

[jira] [Commented] (KAFKA-7316) Use of filter method in KTable.scala may result in StackOverflowError

2018-08-23 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16590446#comment-16590446 ] Guozhang Wang commented on KAFKA-7316: -- [~yuzhih...@gmail.com] the other PR has been merged, I will

[jira] [Updated] (KAFKA-7316) Use of filter method in KTable.scala may result in StackOverflowError

2018-08-23 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-7316: - Fix Version/s: 2.1.0 2.0.1 > Use of filter method in KTable.scala may result

[jira] [Commented] (KAFKA-7316) Use of filter method in KTable.scala may result in StackOverflowError

2018-08-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16590442#comment-16590442 ] ASF GitHub Bot commented on KAFKA-7316: --- guozhangwang closed pull request #5538: KAFKA-7316 Fix

[jira] [Comment Edited] (KAFKA-7314) MirrorMaker example in documentation does not work

2018-08-23 Thread John Wilkinson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16590425#comment-16590425 ] John Wilkinson edited comment on KAFKA-7314 at 8/23/18 4:09 PM: Here are

[jira] [Commented] (KAFKA-7314) MirrorMaker example in documentation does not work

2018-08-23 Thread John Wilkinson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16590425#comment-16590425 ] John Wilkinson commented on KAFKA-7314: --- Here are the docker commands I am using to start the kafka

[jira] [Commented] (KAFKA-7187) offsetsForTimes in MockConsumer implementation

2018-08-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16590413#comment-16590413 ] ASF GitHub Bot commented on KAFKA-7187: --- nucatus opened a new pull request #5561: KAFKA-7187

[jira] [Commented] (KAFKA-7187) offsetsForTimes in MockConsumer implementation

2018-08-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16590409#comment-16590409 ] ASF GitHub Bot commented on KAFKA-7187: --- nucatus closed pull request #5560: KAFKA-7187 MockConsumer

[jira] [Commented] (KAFKA-7187) offsetsForTimes in MockConsumer implementation

2018-08-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16590392#comment-16590392 ] ASF GitHub Bot commented on KAFKA-7187: --- nucatus opened a new pull request #5560: KAFKA-7187

[jira] [Commented] (KAFKA-7314) MirrorMaker example in documentation does not work

2018-08-23 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16590342#comment-16590342 ] Manikumar commented on KAFKA-7314: -- We have unit/system tests to verify the basic mirrormaker scenarios.

[jira] [Commented] (KAFKA-7327) The CPU memory of the kafak master node continues to soar, does not recycle, and finally the service fails?

2018-08-23 Thread ruiliang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16590085#comment-16590085 ] ruiliang commented on KAFKA-7327: - Only the master node does that. What's the situation {code:java}

[jira] [Commented] (KAFKA-7327) The CPU memory of the kafak master node continues to soar, does not recycle, and finally the service fails?

2018-08-23 Thread ruiliang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16589963#comment-16589963 ] ruiliang commented on KAFKA-7327: - After I upgraded from kafka1.1.0 to kafka_2.12 to 2.0.0, now the

[jira] [Updated] (KAFKA-7327) The CPU memory of the kafak master node continues to soar, does not recycle, and finally the service fails?

2018-08-23 Thread ruiliang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ruiliang updated KAFKA-7327: Attachment: server.log.2018-08-23-10 > The CPU memory of the kafak master node continues to soar, does not

[jira] [Commented] (KAFKA-5998) /.checkpoint.tmp Not found exception

2018-08-23 Thread Ayushi (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16589773#comment-16589773 ] Ayushi commented on KAFKA-5998: --- [~guozhang] Requested files: [^Topology.txt] [^streams.txt][^props.txt]

[jira] [Updated] (KAFKA-5998) /.checkpoint.tmp Not found exception

2018-08-23 Thread Ayushi (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ayushi updated KAFKA-5998: -- Attachment: props.txt streams.txt Topology.txt > /.checkpoint.tmp Not found

[jira] [Updated] (KAFKA-5998) /.checkpoint.tmp Not found exception

2018-08-23 Thread Ayushi (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ayushi updated KAFKA-5998: -- Attachment: properties.txt streamsSnippet.txt topology.txt > /.checkpoint.tmp

[jira] [Updated] (KAFKA-7330) Kakfa 0.10.2.1 producer close method issue

2018-08-23 Thread vinay (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinay updated KAFKA-7330: - Description: We are creating new producer connections each time but in separate threads(pool of 40 and all

[jira] [Updated] (KAFKA-5998) /.checkpoint.tmp Not found exception

2018-08-23 Thread Ayushi (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ayushi updated KAFKA-5998: -- Attachment: streamsSnippet.txt topology.txt properties.txt > /.checkpoint.tmp

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

2018-08-23 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6314. -- Resolution: Duplicate Resolving as duplicate of KAFKA-6275 > Add a tool to delete kafka based

[jira] [Created] (KAFKA-7330) Kakfa 0.10.2.1 producer close method issue

2018-08-23 Thread vinay (JIRA)
vinay created KAFKA-7330: Summary: Kakfa 0.10.2.1 producer close method issue Key: KAFKA-7330 URL: https://issues.apache.org/jira/browse/KAFKA-7330 Project: Kafka Issue Type: Bug