[jira] [Commented] (KAFKA-7697) Possible deadlock in kafka.cluster.Partition

2019-04-25 Thread Liu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16826694#comment-16826694 ] Liu commented on KAFKA-7697: [~little brother ma]  wo also hit the same issue with 2.1.1 .I c

[jira] [Commented] (KAFKA-7870) Error sending fetch request (sessionId=1578860481, epoch=INITIAL) to node 2: java.io.IOException: Connection to 2 was disconnected before the response was read.

2019-04-25 Thread Liu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16826664#comment-16826664 ] Liu commented on KAFKA-7870: We actually found this in version 2.1.1 as well > Error sending

[jira] [Comment Edited] (KAFKA-8289) KTable, Long> can't be suppressed

2019-04-25 Thread Xiaolin Jia (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16826634#comment-16826634 ] Xiaolin Jia edited comment on KAFKA-8289 at 4/26/19 4:45 AM: -

[jira] [Comment Edited] (KAFKA-8289) KTable, Long> can't be suppressed

2019-04-25 Thread Xiaolin Jia (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16826634#comment-16826634 ] Xiaolin Jia edited comment on KAFKA-8289 at 4/26/19 4:43 AM: -

[jira] [Comment Edited] (KAFKA-8289) KTable, Long> can't be suppressed

2019-04-25 Thread Xiaolin Jia (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16826634#comment-16826634 ] Xiaolin Jia edited comment on KAFKA-8289 at 4/26/19 4:43 AM: -

[jira] [Commented] (KAFKA-8289) KTable, Long> can't be suppressed

2019-04-25 Thread Xiaolin Jia (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16826634#comment-16826634 ] Xiaolin Jia commented on KAFKA-8289: [~mjsax], Thank you for replying to me. In KAFKA

[jira] [Resolved] (KAFKA-8287) JVM global map to fence duplicate client id

2019-04-25 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-8287. Resolution: Invalid We don't want to do it for now because there are existing use cases where `cli

[jira] [Commented] (KAFKA-8288) KStream.through consumer does not use custom TimestampExtractor

2019-04-25 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16826538#comment-16826538 ] Matthias J. Sax commented on KAFKA-8288: No problem :) I actually opened a PR to

[jira] [Commented] (KAFKA-7903) Replace OffsetCommit request/response with automated protocol

2019-04-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16826536#comment-16826536 ] ASF GitHub Bot commented on KAFKA-7903: --- cmccabe commented on pull request #6583: K

[jira] [Commented] (KAFKA-8282) Missing JMX bandwidth quota metrics for Produce and Fetch

2019-04-25 Thread James Cheng (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16826524#comment-16826524 ] James Cheng commented on KAFKA-8282: In 1.0.0, the behavior was changed such that the

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

2019-04-25 Thread Patrik Kleindl (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16826493#comment-16826493 ] Patrik Kleindl commented on KAFKA-5998: --- Found a new log, again starting with the m

[jira] [Assigned] (KAFKA-6498) Add RocksDB statistics via Streams metrics

2019-04-25 Thread Bruno Cadonna (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna reassigned KAFKA-6498: Assignee: Bruno Cadonna (was: james chien) > Add RocksDB statistics via Streams metrics >

[jira] [Resolved] (KAFKA-8291) System test consumer_test.py failed on trunk

2019-04-25 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-8291. -- Resolution: Fixed Fix Version/s: 2.3.0 > System test consumer_test.py failed on trunk >

[jira] [Created] (KAFKA-8292) Add support for --version parameter to command line tools

2019-04-25 Thread JIRA
Sönke Liebau created KAFKA-8292: --- Summary: Add support for --version parameter to command line tools Key: KAFKA-8292 URL: https://issues.apache.org/jira/browse/KAFKA-8292 Project: Kafka Issue T

[jira] [Commented] (KAFKA-7866) Duplicate offsets after transaction index append failure

2019-04-25 Thread Andrew Olson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16826431#comment-16826431 ] Andrew Olson commented on KAFKA-7866: - [~hachikuji] Do you have an estimated release

[jira] [Commented] (KAFKA-8288) KStream.through consumer does not use custom TimestampExtractor

2019-04-25 Thread Maarten (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16826410#comment-16826410 ] Maarten commented on KAFKA-8288: That explains it, I was under the impression that throug

[jira] [Resolved] (KAFKA-8288) KStream.through consumer does not use custom TimestampExtractor

2019-04-25 Thread Maarten (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maarten resolved KAFKA-8288. Resolution: Invalid > KStream.through consumer does not use custom TimestampExtractor > ---

[jira] [Commented] (KAFKA-8051) remove KafkaMbean when network close

2019-04-25 Thread Andrew Olson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16826387#comment-16826387 ] Andrew Olson commented on KAFKA-8051: - [~monty] It looks like you created 5 duplicate

[jira] [Updated] (KAFKA-8291) System test consumer_test.py failed on trunk

2019-04-25 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-8291: --- Description: Looks like trunk is failing as for now  [https://jenkins.confluent.io/job/system-test-ka

[jira] [Commented] (KAFKA-8291) System test consumer_test.py failed on trunk

2019-04-25 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16826341#comment-16826341 ] Boyang Chen commented on KAFKA-8291: One learning: considering use open source versio

[jira] [Commented] (KAFKA-8290) Streams Not Closing Fenced Producer On Task Close

2019-04-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16826326#comment-16826326 ] ASF GitHub Bot commented on KAFKA-8290: --- bbejeck commented on pull request #6636: K

[jira] [Updated] (KAFKA-8291) System test consumer_test.py failed on trunk

2019-04-25 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-8291: --- Component/s: core consumer > System test consumer_test.py failed on trunk >

[jira] [Updated] (KAFKA-8290) Streams Not Closing Fenced Producer On Task Close

2019-04-25 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8290: --- Description: When a producer is fenced during processing a rebalance is triggered and Kafka Streams c

[jira] [Updated] (KAFKA-8290) Streams Not Closing Fenced Producer On Task Close

2019-04-25 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8290: --- Description: When a producer is fenced during processing and a rebalance is triggered, Kafka Streams

[jira] [Created] (KAFKA-8291) System test consumer_test.py failed on trunk

2019-04-25 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-8291: -- Summary: System test consumer_test.py failed on trunk Key: KAFKA-8291 URL: https://issues.apache.org/jira/browse/KAFKA-8291 Project: Kafka Issue Type: Bug

[jira] [Updated] (KAFKA-8290) Streams Not Closing Fenced Producer On Task Close

2019-04-25 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8290: --- Description: When a producer is fenced during processing and a rebalance is triggered, streams closes

[jira] [Created] (KAFKA-8290) Streams Not Closing Fenced Producer On Task Close

2019-04-25 Thread Bill Bejeck (JIRA)
Bill Bejeck created KAFKA-8290: -- Summary: Streams Not Closing Fenced Producer On Task Close Key: KAFKA-8290 URL: https://issues.apache.org/jira/browse/KAFKA-8290 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-7631) NullPointerException when SCRAM is allowed bu ScramLoginModule is not in broker's jaas.conf

2019-04-25 Thread koert kuipers (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16826229#comment-16826229 ] koert kuipers commented on KAFKA-7631: -- i think i ran into this. brokers are kafka 2

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

2019-04-25 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16826188#comment-16826188 ] Matthias J. Sax commented on KAFKA-5998: In older release, a checkpoint file is w

[jira] [Commented] (KAFKA-8287) JVM global map to fence duplicate client id

2019-04-25 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16826183#comment-16826183 ] Matthias J. Sax commented on KAFKA-8287: Can you elaborate on this proposal? I am

[jira] [Updated] (KAFKA-8287) JVM global map to fence duplicate client id

2019-04-25 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8287: --- Component/s: streams > JVM global map to fence duplicate client id >

[jira] [Updated] (KAFKA-3729) Auto-configure non-default SerDes passed alongside the topology builder

2019-04-25 Thread Richard Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Richard Yu updated KAFKA-3729: -- Labels: api needs-kip newbie (was: api newbie) > Auto-configure non-default SerDes passed alongside t

[jira] [Updated] (KAFKA-3729) Auto-configure non-default SerDes passed alongside the topology builder

2019-04-25 Thread Richard Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Richard Yu updated KAFKA-3729: -- Labels: api needs-dicussion needs-kip newbie (was: api needs-kip newbie) > Auto-configure non-default

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

2019-04-25 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16826169#comment-16826169 ] Matthias J. Sax commented on KAFKA-7895: 2.2.1 release was proposed today. Cf:  [

[jira] [Comment Edited] (KAFKA-8289) KTable, Long> can't be suppressed

2019-04-25 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16826168#comment-16826168 ] Matthias J. Sax edited comment on KAFKA-8289 at 4/25/19 3:33 PM: --

[jira] [Commented] (KAFKA-8289) KTable, Long> can't be suppressed

2019-04-25 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16826168#comment-16826168 ] Matthias J. Sax commented on KAFKA-8289: To what extend is this ticket different

[jira] [Comment Edited] (KAFKA-8289) KTable, Long> can't be suppressed

2019-04-25 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16826168#comment-16826168 ] Matthias J. Sax edited comment on KAFKA-8289 at 4/25/19 3:32 PM: --

[jira] [Commented] (KAFKA-8288) KStream.through consumer does not use custom TimestampExtractor

2019-04-25 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16826166#comment-16826166 ] Matthias J. Sax commented on KAFKA-8288: This behavior is by design. Compare:  ht

[jira] [Updated] (KAFKA-8289) KTable, Long> can't be suppressed

2019-04-25 Thread Xiaolin Jia (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xiaolin Jia updated KAFKA-8289: --- Description: I write a simple stream app followed official developer guide [Stream DSL|[https://kafk

[jira] [Updated] (KAFKA-8289) KTable, Long> can't be suppressed

2019-04-25 Thread Xiaolin Jia (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xiaolin Jia updated KAFKA-8289: --- Description: I write a simple stream app followed official developer guide [Stream DSL|[https://kafk

[jira] [Issue Comment Deleted] (KAFKA-8289) KTable, Long> can't be suppressed

2019-04-25 Thread Xiaolin Jia (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xiaolin Jia updated KAFKA-8289: --- Comment: was deleted (was: Can a [SessionWindowedKStream] be suppressed after count operation? It se

[jira] [Updated] (KAFKA-8289) KTable, Long> can't be suppressed

2019-04-25 Thread Xiaolin Jia (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xiaolin Jia updated KAFKA-8289: --- Description: I write a simple stream app followed official developer guide [Stream DSL|[https://kafk

[jira] [Updated] (KAFKA-8289) KTable, Long> can't be suppressed

2019-04-25 Thread Xiaolin Jia (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xiaolin Jia updated KAFKA-8289: --- Description: I write a simple stream app followed official developer guide [Stream DSL|[https://kafk

[jira] [Comment Edited] (KAFKA-8289) KTable, Long> can't be suppressed

2019-04-25 Thread Xiaolin Jia (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16825833#comment-16825833 ] Xiaolin Jia edited comment on KAFKA-8289 at 4/25/19 8:06 AM: -

[jira] [Comment Edited] (KAFKA-8289) KTable, Long> can't be suppressed

2019-04-25 Thread Xiaolin Jia (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16825833#comment-16825833 ] Xiaolin Jia edited comment on KAFKA-8289 at 4/25/19 7:58 AM: -

[jira] [Comment Edited] (KAFKA-8289) KTable, Long> can't be suppressed

2019-04-25 Thread Xiaolin Jia (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16825833#comment-16825833 ] Xiaolin Jia edited comment on KAFKA-8289 at 4/25/19 7:57 AM: -

[jira] [Comment Edited] (KAFKA-8289) KTable, Long> can't be suppressed

2019-04-25 Thread Xiaolin Jia (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16825833#comment-16825833 ] Xiaolin Jia edited comment on KAFKA-8289 at 4/25/19 7:56 AM: -

[jira] [Commented] (KAFKA-8289) KTable, Long> can't be suppressed

2019-04-25 Thread Xiaolin Jia (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16825833#comment-16825833 ] Xiaolin Jia commented on KAFKA-8289: Can a  [SessionWindowedKStream|eclipse-javadoc:%

[jira] [Updated] (KAFKA-8289) KTable, Long> can't be suppressed

2019-04-25 Thread Xiaolin Jia (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xiaolin Jia updated KAFKA-8289: --- Priority: Blocker (was: Major) > KTable, Long> can't be suppressed > --

[jira] [Created] (KAFKA-8289) KTable, Long> can't be suppressed

2019-04-25 Thread Xiaolin Jia (JIRA)
Xiaolin Jia created KAFKA-8289: -- Summary: KTable, Long> can't be suppressed Key: KAFKA-8289 URL: https://issues.apache.org/jira/browse/KAFKA-8289 Project: Kafka Issue Type: Bug Compon

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

2019-04-25 Thread Patrik Kleindl (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16825821#comment-16825821 ] Patrik Kleindl commented on KAFKA-5998: --- This issue was what led me to https://issu

[jira] [Created] (KAFKA-8288) KStream.through consumer does not use custom TimestampExtractor

2019-04-25 Thread Maarten (JIRA)
Maarten created KAFKA-8288: -- Summary: KStream.through consumer does not use custom TimestampExtractor Key: KAFKA-8288 URL: https://issues.apache.org/jira/browse/KAFKA-8288 Project: Kafka Issue Type

[jira] [Commented] (KAFKA-8173) Kafka Errors after version upgrade from 0.10.2.2 to 2.1.1

2019-04-25 Thread Arpit Khare (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16825808#comment-16825808 ] Arpit Khare commented on KAFKA-8173: [~regexcracker] This issue occurs because of cor