[jira] [Commented] (KAFKA-6749) TopologyTestDriver fails when topoloy under test uses EXACTLY_ONCE

[ https://issues.apache.org/jira/browse/KAFKA-6749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472905#comment-16472905 ] ASF GitHub Bot commented on KAFKA-6749: --- jadireddi closed pull request #4912: KAFKA-6749: Fixed

[jira] [Commented] (KAFKA-6749) TopologyTestDriver fails when topoloy under test uses EXACTLY_ONCE

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

[jira] [Commented] (KAFKA-5611) One or more consumers in a consumer-group stop consuming after rebalancing

[ https://issues.apache.org/jira/browse/KAFKA-5611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16471522#comment-16471522 ] qiuyueqiong commented on KAFKA-5611: after applied https://github.com/apache/kafka/pull/3571 on

[jira] [Commented] (KAFKA-6892) Kafka Streams memory usage grows over the time till OOM

[ https://issues.apache.org/jira/browse/KAFKA-6892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16471647#comment-16471647 ] Dawid Kulig commented on KAFKA-6892: [~mjsax] Thank you for your comment. Shame on me but I must have

[jira] [Comment Edited] (KAFKA-6892) Kafka Streams memory usage grows over the time till OOM

[ https://issues.apache.org/jira/browse/KAFKA-6892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16471647#comment-16471647 ] Dawid Kulig edited comment on KAFKA-6892 at 5/11/18 8:33 AM: - [~mjsax] Thank

[jira] [Updated] (KAFKA-6892) Kafka Streams memory usage grows over the time till OOM

[ https://issues.apache.org/jira/browse/KAFKA-6892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Kulig updated KAFKA-6892: --- Description: Hi. I am observing indefinite memory growth of my kafka-streams application. It gets

[jira] [Created] (KAFKA-6898) org.apache.kafka.common.errors.TimeoutException

Rishi created KAFKA-6898: Summary: org.apache.kafka.common.errors.TimeoutException Key: KAFKA-6898 URL: https://issues.apache.org/jira/browse/KAFKA-6898 Project: Kafka Issue Type: Bug Affects

[jira] [Updated] (KAFKA-6830) Add new metrics for consumer/replication fetch requests

[ https://issues.apache.org/jira/browse/KAFKA-6830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Adam Kotwasinski updated KAFKA-6830: Description: Currently, we have only one fetch request-related metric for a topic. As

[jira] [Commented] (KAFKA-6830) Add new metrics for consumer/replication fetch requests

[ https://issues.apache.org/jira/browse/KAFKA-6830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16471673#comment-16471673 ] Adam Kotwasinski commented on KAFKA-6830: - KIP - 

[jira] [Commented] (KAFKA-5965) Remove Deprecated AdminClient from Streams Resetter Tool

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

[jira] [Resolved] (KAFKA-5965) Remove Deprecated AdminClient from Streams Resetter Tool

[ https://issues.apache.org/jira/browse/KAFKA-5965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-5965. -- Resolution: Fixed Fix Version/s: 2.0.0 > Remove Deprecated AdminClient from Streams

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

[ https://issues.apache.org/jira/browse/KAFKA-6884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472117#comment-16472117 ] Jason Gustafson commented on KAFKA-6884: Thanks [~asasvari]. I think the assignment strategy is

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

[ https://issues.apache.org/jira/browse/KAFKA-6884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472041#comment-16472041 ] Attila Sasvari commented on KAFKA-6884: --- It seems assignmentStrategy is also needed. Added some new

[jira] [Commented] (KAFKA-6394) Prevent misconfiguration of advertised listeners

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

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

[ https://issues.apache.org/jira/browse/KAFKA-6884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16471932#comment-16471932 ] Attila Sasvari commented on KAFKA-6884: --- [~hachikuji] Thanks, I downloaded the pull request as a

[jira] [Commented] (KAFKA-6566) SourceTask#stop() not called after exception raised in poll()

[ https://issues.apache.org/jira/browse/KAFKA-6566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472374#comment-16472374 ] Robert Yokota commented on KAFKA-6566: -- I've just started looking at this, but it looks like the

[jira] [Resolved] (KAFKA-6813) Remove deprecated APIs from KIP-120 and KIP-182 in Streams

[ https://issues.apache.org/jira/browse/KAFKA-6813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6813. -- Resolution: Fixed > Remove deprecated APIs from KIP-120 and KIP-182 in Streams >

[jira] [Updated] (KAFKA-6566) SourceTask#stop() not called after exception raised in poll()

[ https://issues.apache.org/jira/browse/KAFKA-6566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-6566: -- Attachment: 6566.txt > SourceTask#stop() not called after exception raised in poll() >

[jira] [Commented] (KAFKA-6566) SourceTask#stop() not called after exception raised in poll()

[ https://issues.apache.org/jira/browse/KAFKA-6566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472411#comment-16472411 ] Ted Yu commented on KAFKA-6566: --- Attached 6566.txt, reflecting Robert's comment. Waiting for Randall's

[jira] [Comment Edited] (KAFKA-6566) SourceTask#stop() not called after exception raised in poll()

[ https://issues.apache.org/jira/browse/KAFKA-6566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472374#comment-16472374 ] Robert Yokota edited comment on KAFKA-6566 at 5/11/18 6:04 PM: --- I've just

[jira] [Resolved] (KAFKA-6394) Prevent misconfiguration of advertised listeners

[ https://issues.apache.org/jira/browse/KAFKA-6394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6394. Resolution: Fixed Fix Version/s: 2.0.0 > Prevent misconfiguration of advertised

[jira] [Commented] (KAFKA-6892) Kafka Streams memory usage grows over the time till OOM

[ https://issues.apache.org/jira/browse/KAFKA-6892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472257#comment-16472257 ] Matthias J. Sax commented on KAFKA-6892: Thanks for the details. Hard to say. But as you use

[jira] [Commented] (KAFKA-4849) Bug in KafkaStreams documentation

[ https://issues.apache.org/jira/browse/KAFKA-4849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472322#comment-16472322 ] ASF GitHub Bot commented on KAFKA-4849: --- mjsax closed pull request #2648: KAFKA-4849: Bug in

[jira] [Issue Comment Deleted] (KAFKA-6566) SourceTask#stop() not called after exception raised in poll()

[ https://issues.apache.org/jira/browse/KAFKA-6566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-6566: -- Comment: was deleted (was: Attached 6566.txt, reflecting Robert's comment. Waiting for Randall's response.) >

[jira] [Commented] (KAFKA-4217) KStream.transform equivalent of flatMap

[ https://issues.apache.org/jira/browse/KAFKA-4217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472553#comment-16472553 ] Matthias J. Sax commented on KAFKA-4217: It's just a question of the API – returning "zero or more

[jira] [Assigned] (KAFKA-6566) SourceTask#stop() not called after exception raised in poll()

[ https://issues.apache.org/jira/browse/KAFKA-6566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch reassigned KAFKA-6566: Assignee: Robert Yokota Priority: Blocker (was: Major) Fix Version/s:

[jira] [Commented] (KAFKA-4217) KStream.transform equivalent of flatMap

[ https://issues.apache.org/jira/browse/KAFKA-4217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472499#comment-16472499 ] Bruno Cadonna commented on KAFKA-4217: -- Is this issue still relevant? The docs of 

[jira] [Updated] (KAFKA-6566) SourceTask#stop() not called after exception raised in poll()

[ https://issues.apache.org/jira/browse/KAFKA-6566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-6566: -- Attachment: (was: 6566.txt) > SourceTask#stop() not called after exception raised in poll() >

[jira] [Commented] (KAFKA-6738) Kafka Connect handling of bad data

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