[jira] [Commented] (KAFKA-4600) Consumer proceeds on when ConsumerRebalanceListener fails

2019-04-08 Thread Braedon Vickers (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16812168#comment-16812168 ] Braedon Vickers commented on KAFKA-4600: Hi [~guozhang], Sounds like we are on t

[jira] [Commented] (KAFKA-8194) MessagesInPerSec incorrect value when Stream produce messages

2019-04-08 Thread Odyldzhon Toshbekov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16812303#comment-16812303 ] Odyldzhon Toshbekov commented on KAFKA-8194: [~guozhang] I can do it during t

[jira] [Commented] (KAFKA-7983) supporting replication.throttled.replicas in dynamic broker configuration

2019-04-08 Thread Rahul Agarwal (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16812313#comment-16812313 ] Rahul Agarwal commented on KAFKA-7983: -- Can you please assign this ticket to me?  J

[jira] [Commented] (KAFKA-7965) Flaky Test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

2019-04-08 Thread huxihx (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16812335#comment-16812335 ] huxihx commented on KAFKA-7965: --- Seems [PR 6328|[https://github.com/apache/kafka/pull/6238]

[jira] [Comment Edited] (KAFKA-7965) Flaky Test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

2019-04-08 Thread huxihx (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16812335#comment-16812335 ] huxihx edited comment on KAFKA-7965 at 4/8/19 10:51 AM: Seems [ht

[jira] [Created] (KAFKA-8199) ClassCastException when trying to groupBy after suppress

2019-04-08 Thread Bill Bejeck (JIRA)
Bill Bejeck created KAFKA-8199: -- Summary: ClassCastException when trying to groupBy after suppress Key: KAFKA-8199 URL: https://issues.apache.org/jira/browse/KAFKA-8199 Project: Kafka Issue Type

[jira] [Updated] (KAFKA-8199) ClassCastException when trying to groupBy after suppress

2019-04-08 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8199: --- Description: A topology with a groupBy after a suppress operation results in a ClassCastException  

[jira] [Updated] (KAFKA-8199) ClassCastException when trying to groupBy after suppress

2019-04-08 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8199: --- Description: A topology with a groupBy after a suppress operation results in a ClassCastException  

[jira] [Updated] (KAFKA-8199) ClassCastException when trying to groupBy after suppress

2019-04-08 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8199: --- Description: A topology with a groupBy after a suppress operation results in a ClassCastException  

[jira] [Updated] (KAFKA-8199) ClassCastException when trying to groupBy after suppress

2019-04-08 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8199: --- Description: A topology with a groupBy after a suppress operation results in a ClassCastException  

[jira] [Assigned] (KAFKA-7983) supporting replication.throttled.replicas in dynamic broker configuration

2019-04-08 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao reassigned KAFKA-7983: -- Assignee: Rahul Agarwal > supporting replication.throttled.replicas in dynamic broker configuration >

[jira] [Commented] (KAFKA-7983) supporting replication.throttled.replicas in dynamic broker configuration

2019-04-08 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16812556#comment-16812556 ] Jun Rao commented on KAFKA-7983: [~rahul.mnit], just added you to the contributor list an

[jira] [Resolved] (KAFKA-8157) Missing "key.serializer" exception when setting "segment index bytes"

2019-04-08 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-8157. -- Resolution: Fixed Assignee: Guozhang Wang Fix Version/s: 2.2.1

[jira] [Commented] (KAFKA-6474) Rewrite test to use new public TopologyTestDriver

2019-04-08 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16812597#comment-16812597 ] Guozhang Wang commented on KAFKA-6474: -- Hi [~h314to] could you provide an update on

[jira] [Commented] (KAFKA-8194) MessagesInPerSec incorrect value when Stream produce messages

2019-04-08 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16812629#comment-16812629 ] Guozhang Wang commented on KAFKA-8194: -- [~odyldz...@gmail.com] I've added you to the

[jira] [Resolved] (KAFKA-5784) Add a sensor for dropped records in window stores

2019-04-08 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-5784. -- Resolution: Fixed Fix Version/s: 2.1.0 > Add a sensor for dropped records in window stor

[jira] [Commented] (KAFKA-5784) Add a sensor for dropped records in window stores

2019-04-08 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5784?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16812664#comment-16812664 ] Guozhang Wang commented on KAFKA-5784: -- I think this is already added as part of [~v

[jira] [Commented] (KAFKA-7841) KIP-419 Safely notify Kafka Connect SourceTask is stopped

2019-04-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16812711#comment-16812711 ] ASF GitHub Bot commented on KAFKA-7841: --- AndrewJSchofield commented on pull request

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

2019-04-08 Thread Mohan Parthasarathy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16812743#comment-16812743 ] Mohan Parthasarathy commented on KAFKA-5998: That did not seem to help much.

[jira] [Assigned] (KAFKA-8169) Wrong topic on streams quick start documentation

2019-04-08 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-8169: -- Assignee: Tcheutchoua Steve > Wrong topic on streams quick start documentation > -

[jira] [Resolved] (KAFKA-8169) Wrong topic on streams quick start documentation

2019-04-08 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-8169. Resolution: Fixed Fix Version/s: 2.3.0 [~tcheutchoua], I added you to the list of co

[jira] [Updated] (KAFKA-8169) Wrong topic on streams quick start documentation

2019-04-08 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8169: --- Component/s: streams > Wrong topic on streams quick start documentation > ---

[jira] [Updated] (KAFKA-8198) KStreams testing docs use non-existent method "pipe"

2019-04-08 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8198: --- Component/s: streams documentation > KStreams testing docs use non-existent

[jira] [Resolved] (KAFKA-8181) Streams docs on serialization include Avro header, but no content

2019-04-08 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-8181. Resolution: Fixed Fix Version/s: 2.3.0 > Streams docs on serialization include Avro

[jira] [Updated] (KAFKA-8193) Flaky Test MetricsIntegrationTest#testStreamMetricOfWindowStore

2019-04-08 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8193: --- Component/s: (was: admin) streams > Flaky Test MetricsIntegrationTest#te

[jira] [Commented] (KAFKA-7895) Ktable supress operator emitting more than one record for the same key per window

2019-04-08 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16812787#comment-16812787 ] John Roesler commented on KAFKA-7895: - No problem. Thanks for _your_ help! The PR is

[jira] [Commented] (KAFKA-8194) MessagesInPerSec incorrect value when Stream produce messages

2019-04-08 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16812790#comment-16812790 ] Matthias J. Sax commented on KAFKA-8194: Seems the Jira title is miss leading? Ca

[jira] [Updated] (KAFKA-8174) Can't call arbitrary SimpleBenchmarks tests from streams_simple_benchmark_test.py

2019-04-08 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8174: --- Issue Type: Improvement (was: Bug) > Can't call arbitrary SimpleBenchmarks tests from > str

[jira] [Updated] (KAFKA-8174) Can't call arbitrary SimpleBenchmarks tests from streams_simple_benchmark_test.py

2019-04-08 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8174: --- Component/s: system tests streams > Can't call arbitrary SimpleBenchmarks te

[jira] [Updated] (KAFKA-6399) Consider reducing "max.poll.interval.ms" default for Kafka Streams

2019-04-08 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6399: --- Fix Version/s: 2.3.0 > Consider reducing "max.poll.interval.ms" default for Kafka Streams > -

[jira] [Resolved] (KAFKA-8013) Avoid buffer underflow when reading a Struct from a partially correct buffer

2019-04-08 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-8013. Resolution: Fixed > Avoid buffer underflow when reading a Struct from a partially correct b

[jira] [Commented] (KAFKA-8013) Avoid buffer underflow when reading a Struct from a partially correct buffer

2019-04-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16812804#comment-16812804 ] ASF GitHub Bot commented on KAFKA-8013: --- hachikuji commented on pull request #6340:

[jira] [Commented] (KAFKA-7656) ReplicaManager fetch fails on leader due to long/integer overflow

2019-04-08 Thread Jonathan Santilli (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16812809#comment-16812809 ] Jonathan Santilli commented on KAFKA-7656: -- I facing the same issue, but just af

[jira] [Assigned] (KAFKA-8181) Streams docs on serialization include Avro header, but no content

2019-04-08 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-8181: -- Assignee: Victoria Bialas > Streams docs on serialization include Avro header, but no

[jira] [Commented] (KAFKA-7656) ReplicaManager fetch fails on leader due to long/integer overflow

2019-04-08 Thread Jose Armando Garcia Sancio (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16812823#comment-16812823 ] Jose Armando Garcia Sancio commented on KAFKA-7656: --- [~pachilo], thanks

[jira] [Commented] (KAFKA-7656) ReplicaManager fetch fails on leader due to long/integer overflow

2019-04-08 Thread Jose Armando Garcia Sancio (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16812825#comment-16812825 ] Jose Armando Garcia Sancio commented on KAFKA-7656: --- Also, [~pachilo],

[jira] [Comment Edited] (KAFKA-7656) ReplicaManager fetch fails on leader due to long/integer overflow

2019-04-08 Thread Jose Armando Garcia Sancio (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16812825#comment-16812825 ] Jose Armando Garcia Sancio edited comment on KAFKA-7656 at 4/8/19 9:51 PM:

[jira] [Created] (KAFKA-8200) TopologyTestDriver should offer an iterable signature of readOutput

2019-04-08 Thread Michael Drogalis (JIRA)
Michael Drogalis created KAFKA-8200: --- Summary: TopologyTestDriver should offer an iterable signature of readOutput Key: KAFKA-8200 URL: https://issues.apache.org/jira/browse/KAFKA-8200 Project: Kafk

[jira] [Commented] (KAFKA-8108) Flaky Test kafka.api.ClientIdQuotaTest.testThrottledProducerConsumer

2019-04-08 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16812847#comment-16812847 ] Guozhang Wang commented on KAFKA-8108: -- Happened again: https://builds.apache.org/j

[jira] [Commented] (KAFKA-4600) Consumer proceeds on when ConsumerRebalanceListener fails

2019-04-08 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16812848#comment-16812848 ] Guozhang Wang commented on KAFKA-4600: -- [~braedon] I think your argument makes sense

[jira] [Updated] (KAFKA-8200) TopologyTestDriver should offer an iterable signature of readOutput

2019-04-08 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8200: --- Component/s: streams > TopologyTestDriver should offer an iterable signature of readOutput >

[jira] [Updated] (KAFKA-8200) TopologyTestDriver should offer an iterable signature of readOutput

2019-04-08 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8200: --- Labels: needs-kip (was: ) > TopologyTestDriver should offer an iterable signature of readOut

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

2019-04-08 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5998: - Priority: Critical (was: Major) > /.checkpoint.tmp Not found exception > ---

[jira] [Updated] (KAFKA-6399) Consider reducing "max.poll.interval.ms" default for Kafka Streams

2019-04-08 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6399: --- Description: In Kafka {{0.10.2.1}} we change the default value of {{max.poll.intervall.ms}}

[jira] [Updated] (KAFKA-6399) Consider reducing "max.poll.interval.ms" default for Kafka Streams

2019-04-08 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6399: --- Labels: kip (was: ) > Consider reducing "max.poll.interval.ms" default for Kafka Streams > -

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

2019-04-08 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16813009#comment-16813009 ] Guozhang Wang commented on KAFKA-5998: -- This seems affecting lots of people's file s

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

2019-04-08 Thread Mohan Parthasarathy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16813012#comment-16813012 ] Mohan Parthasarathy commented on KAFKA-5998: I am not able to find the enviro