[jira] [Commented] (KAFKA-6953) [Streams] Schedulable KTable as Graph source (for minimizing aggregation pressure)

2018-05-26 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16491939#comment-16491939 ] Matthias J. Sax commented on KAFKA-6953: Thanks for sharing more details. I guess

[jira] [Commented] (KAFKA-6953) [Streams] Schedulable KTable as Graph source (for minimizing aggregation pressure)

2018-05-26 Thread Flavio Stutz (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16491914#comment-16491914 ] Flavio Stutz commented on KAFKA-6953: - I used the "message count" example for simplici

[jira] [Updated] (KAFKA-6952) LogCleaner stopped due to org.apache.kafka.common.errors.CorruptRecordException

2018-05-26 Thread evan einst (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] evan einst updated KAFKA-6952: -- Attachment: __consumer_offsets-30-3.zip > LogCleaner stopped due to > org.apache.kafka.common.errors.Co

[jira] [Commented] (KAFKA-6952) LogCleaner stopped due to org.apache.kafka.common.errors.CorruptRecordException

2018-05-26 Thread evan einst (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16491899#comment-16491899 ] evan einst commented on KAFKA-6952: --- I run this command on __consumer_offsets-30(same er

[jira] [Updated] (KAFKA-6952) LogCleaner stopped due to org.apache.kafka.common.errors.CorruptRecordException

2018-05-26 Thread evan einst (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] evan einst updated KAFKA-6952: -- Attachment: __consumer_offsets-30_1.zip > LogCleaner stopped due to > org.apache.kafka.common.errors.Co

[jira] [Updated] (KAFKA-6952) LogCleaner stopped due to org.apache.kafka.common.errors.CorruptRecordException

2018-05-26 Thread evan einst (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] evan einst updated KAFKA-6952: -- Attachment: __consumer_offsets-30-2.zip > LogCleaner stopped due to > org.apache.kafka.common.errors.Co

[jira] [Assigned] (KAFKA-6955) Use Java AdminClient in DeleteRecordsCommand

2018-05-26 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian reassigned KAFKA-6955: -- Assignee: Vahid Hashemian > Use Java AdminClient in DeleteRecordsCommand >

[jira] [Assigned] (KAFKA-6956) Use Java AdminClient in BrokerApiVersionsCommand

2018-05-26 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian reassigned KAFKA-6956: -- Assignee: Vahid Hashemian > Use Java AdminClient in BrokerApiVersionsCommand >

[jira] [Commented] (KAFKA-6957) Add getter to AbstractStream class to make internalTopologyBuilder accessible outside of package

2018-05-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6957?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16491800#comment-16491800 ] ASF GitHub Bot commented on KAFKA-6957: --- fhussonnois opened a new pull request #5085

[jira] [Created] (KAFKA-6957) Add getter to AbstractStream class to make internalTopologyBuilder accessible outside of package

2018-05-26 Thread Florian Hussonnois (JIRA)
Florian Hussonnois created KAFKA-6957: - Summary: Add getter to AbstractStream class to make internalTopologyBuilder accessible outside of package Key: KAFKA-6957 URL: https://issues.apache.org/jira/browse/KAFK

[jira] [Resolved] (KAFKA-5697) StreamThread.shutdown() need to interrupt the stream threads to break the loop

2018-05-26 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-5697. Resolution: Fixed Fix Version/s: 2.0.0 > StreamThread.shutdown() need to interrupt th

[jira] [Commented] (KAFKA-6953) [Streams] Schedulable KTable as Graph source (for minimizing aggregation pressure)

2018-05-26 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16491781#comment-16491781 ] Matthias J. Sax commented on KAFKA-6953: Couple of comments:  - With sufficiently

[jira] [Commented] (KAFKA-3340) Add support for rebalance and adding concurrently records with MockConsumer

2018-05-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16491777#comment-16491777 ] ASF GitHub Bot commented on KAFKA-3340: --- fhussonnois closed pull request #1016: KAFK

[jira] [Commented] (KAFKA-6952) LogCleaner stopped due to org.apache.kafka.common.errors.CorruptRecordException

2018-05-26 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16491723#comment-16491723 ] Jun Rao commented on KAFKA-6952: Hmm, could you run bin/kafka-run-class.sh kafka.tools.Dum

[jira] [Commented] (KAFKA-3355) GetOffsetShell command doesn't work with SASL enabled Kafka

2018-05-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16491721#comment-16491721 ] ASF GitHub Bot commented on KAFKA-3355: --- ijuma closed pull request #5028: KAFKA-3355

[jira] [Updated] (KAFKA-6955) Use Java AdminClient in DeleteRecordsCommand

2018-05-26 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-6955: --- Labels: newbie (was: ) > Use Java AdminClient in DeleteRecordsCommand > -

[jira] [Created] (KAFKA-6956) Use Java AdminClient in BrokerApiVersionsCommand

2018-05-26 Thread Ismael Juma (JIRA)
Ismael Juma created KAFKA-6956: -- Summary: Use Java AdminClient in BrokerApiVersionsCommand Key: KAFKA-6956 URL: https://issues.apache.org/jira/browse/KAFKA-6956 Project: Kafka Issue Type: Improv

[jira] [Created] (KAFKA-6955) Use Java AdminClient in DeleteRecordsCommand

2018-05-26 Thread Ismael Juma (JIRA)
Ismael Juma created KAFKA-6955: -- Summary: Use Java AdminClient in DeleteRecordsCommand Key: KAFKA-6955 URL: https://issues.apache.org/jira/browse/KAFKA-6955 Project: Kafka Issue Type: Improvemen

[jira] [Updated] (KAFKA-6884) ConsumerGroupCommand should use new AdminClient

2018-05-26 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-6884: --- Fix Version/s: 2.0.0 > ConsumerGroupCommand should use new AdminClient > -

[jira] [Comment Edited] (KAFKA-3387) Update GetOffsetShell tool to not rely on old producer.

2018-05-26 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16491704#comment-16491704 ] Ismael Juma edited comment on KAFKA-3387 at 5/26/18 3:38 PM: -

[jira] [Updated] (KAFKA-6952) LogCleaner stopped due to org.apache.kafka.common.errors.CorruptRecordException

2018-05-26 Thread evan einst (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] evan einst updated KAFKA-6952: -- Description: This error occur our prd cluster 0.10.2.1 upgrading to the 0.11.0.2 version,  here said(ht

[jira] [Updated] (KAFKA-6952) LogCleaner stopped due to org.apache.kafka.common.errors.CorruptRecordException

2018-05-26 Thread evan einst (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] evan einst updated KAFKA-6952: -- Description: This error occur our prd cluster 0.10.2.1 upgrading to the 0.11.0.2 version,  here said(ht

[jira] [Commented] (KAFKA-3387) Update GetOffsetShell tool to not rely on old producer.

2018-05-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16491702#comment-16491702 ] ASF GitHub Bot commented on KAFKA-3387: --- ijuma closed pull request #1076: KAFKA-3387

[jira] [Commented] (KAFKA-3387) Update GetOffsetShell tool to not rely on old producer.

2018-05-26 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16491704#comment-16491704 ] Ismael Juma commented on KAFKA-3387: Removed by https://github.com/apache/kafka/commi

[jira] [Created] (KAFKA-6954) Add a new tool to loading data from file

2018-05-26 Thread darion yaphet (JIRA)
darion yaphet created KAFKA-6954: Summary: Add a new tool to loading data from file Key: KAFKA-6954 URL: https://issues.apache.org/jira/browse/KAFKA-6954 Project: Kafka Issue Type: New Featur

[jira] [Updated] (KAFKA-6952) LogCleaner stopped due to org.apache.kafka.common.errors.CorruptRecordException

2018-05-26 Thread evan einst (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] evan einst updated KAFKA-6952: -- Description: This error occur our prd cluster 0.10.2.1 upgrading to the 0.11.0.2 version,  here said(ht

[jira] [Created] (KAFKA-6953) [Streams] Schedulable KTable as Graph source (for minimizing aggregation pressure)

2018-05-26 Thread Flavio Stutz (JIRA)
Flavio Stutz created KAFKA-6953: --- Summary: [Streams] Schedulable KTable as Graph source (for minimizing aggregation pressure) Key: KAFKA-6953 URL: https://issues.apache.org/jira/browse/KAFKA-6953 Projec

[jira] [Created] (KAFKA-6952) LogCleaner stopped due to org.apache.kafka.common.errors.CorruptRecordException

2018-05-26 Thread evan einst (JIRA)
evan einst created KAFKA-6952: - Summary: LogCleaner stopped due to org.apache.kafka.common.errors.CorruptRecordException Key: KAFKA-6952 URL: https://issues.apache.org/jira/browse/KAFKA-6952 Project: Kafk

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

2018-05-26 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6929. -- Resolution: Fixed Fix Version/s: 2.0.0 Fixed via https://github.com/apache/kafka/pull/5060 > ZkD

[jira] [Commented] (KAFKA-6947) Mirrormaker Closing producer due to send failure

2018-05-26 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16491626#comment-16491626 ] Manikumar commented on KAFKA-6947: -- By default mirror maker config property "abort.on.sen

[jira] [Commented] (KAFKA-6900) Add thenCompose to KafkaFuture

2018-05-26 Thread Richard Tjerngren (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16491604#comment-16491604 ] Richard Tjerngren commented on KAFKA-6900: -- Changes available at https://github.c