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

[ https://issues.apache.org/jira/browse/KAFKA-8289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16826634#comment-16826634 ] Xiaolin Jia edited comment on KAFKA-8289 at 4/26/19 4:45 AM: - [~mjsax], Thank

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

[ https://issues.apache.org/jira/browse/KAFKA-8289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16826634#comment-16826634 ] Xiaolin Jia edited comment on KAFKA-8289 at 4/26/19 4:43 AM: - [~mjsax], Thank

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

[ https://issues.apache.org/jira/browse/KAFKA-8289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16826634#comment-16826634 ] Xiaolin Jia edited comment on KAFKA-8289 at 4/26/19 4:43 AM: - [~mjsax], Thank

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

[ https://issues.apache.org/jira/browse/KAFKA-8289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16826634#comment-16826634 ] Xiaolin Jia commented on KAFKA-8289: [~mjsax], Thank you for replying to me. In KAFKA-7895  John was

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

[ 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

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

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

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

[ https://issues.apache.org/jira/browse/KAFKA-7903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16826536#comment-16826536 ] ASF GitHub Bot commented on KAFKA-7903: --- cmccabe commented on pull request #6583: KAFKA-7903 : use

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

[ https://issues.apache.org/jira/browse/KAFKA-8282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16826524#comment-16826524 ] James Cheng commented on KAFKA-8282: In 1.0.0, the behavior was changed such that these metrics are

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

[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16826493#comment-16826493 ] Patrik Kleindl commented on KAFKA-5998: --- Found a new log, again starting with the message after the

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

[ 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

[ 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

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

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

[ https://issues.apache.org/jira/browse/KAFKA-7866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16826431#comment-16826431 ] Andrew Olson commented on KAFKA-7866: - [~hachikuji] Do you have an estimated release data for 2.2.1?

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

[ https://issues.apache.org/jira/browse/KAFKA-8288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16826410#comment-16826410 ] Maarten commented on KAFKA-8288: That explains it, I was under the impression that through would produce

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

[ 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

[ https://issues.apache.org/jira/browse/KAFKA-8051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16826387#comment-16826387 ] Andrew Olson commented on KAFKA-8051: - [~monty] It looks like you created 5 duplicate issues,

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

[ 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 

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

[ https://issues.apache.org/jira/browse/KAFKA-8291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16826341#comment-16826341 ] Boyang Chen commented on KAFKA-8291: One learning: considering use open source version in default

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

[ https://issues.apache.org/jira/browse/KAFKA-8290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16826326#comment-16826326 ] ASF GitHub Bot commented on KAFKA-8290: --- bbejeck commented on pull request #6636: KAFKA-8290: Close

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

[ 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

[ 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

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

[ 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

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

[ 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

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

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

[ https://issues.apache.org/jira/browse/KAFKA-7631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16826229#comment-16826229 ] koert kuipers commented on KAFKA-7631: -- i think i ran into this. brokers are kafka 2.2.0. my

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

[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16826188#comment-16826188 ] Matthias J. Sax commented on KAFKA-5998: In older release, a checkpoint file is written for all

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

[ https://issues.apache.org/jira/browse/KAFKA-8287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16826183#comment-16826183 ] Matthias J. Sax commented on KAFKA-8287: Can you elaborate on this proposal? I am not sure if

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

[ 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

[ 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

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

[ 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

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

[ https://issues.apache.org/jira/browse/KAFKA-7895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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

[ https://issues.apache.org/jira/browse/KAFKA-8289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16826168#comment-16826168 ] Matthias J. Sax edited comment on KAFKA-8289 at 4/25/19 3:33 PM: - To what

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

[ https://issues.apache.org/jira/browse/KAFKA-8289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16826168#comment-16826168 ] Matthias J. Sax commented on KAFKA-8289: To what extend is this ticket different to KAFKA-7895?

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

[ https://issues.apache.org/jira/browse/KAFKA-8289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16826168#comment-16826168 ] Matthias J. Sax edited comment on KAFKA-8289 at 4/25/19 3:32 PM: - To what

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

[ https://issues.apache.org/jira/browse/KAFKA-8288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16826166#comment-16826166 ] Matthias J. Sax commented on KAFKA-8288: This behavior is by design. Compare: 

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

[ 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

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

[ 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

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

[ 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

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

[ 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

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

[ 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

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

[ https://issues.apache.org/jira/browse/KAFKA-8289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16825833#comment-16825833 ] Xiaolin Jia edited comment on KAFKA-8289 at 4/25/19 8:06 AM: - Can a

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

[ https://issues.apache.org/jira/browse/KAFKA-8289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16825833#comment-16825833 ] Xiaolin Jia edited comment on KAFKA-8289 at 4/25/19 7:58 AM: - Can a

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

[ https://issues.apache.org/jira/browse/KAFKA-8289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16825833#comment-16825833 ] Xiaolin Jia edited comment on KAFKA-8289 at 4/25/19 7:57 AM: - Can a

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

[ https://issues.apache.org/jira/browse/KAFKA-8289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16825833#comment-16825833 ] Xiaolin Jia edited comment on KAFKA-8289 at 4/25/19 7:56 AM: - Can a

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

[ https://issues.apache.org/jira/browse/KAFKA-8289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16825833#comment-16825833 ] Xiaolin Jia commented on KAFKA-8289: Can a 

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

[ 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

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

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

[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16825821#comment-16825821 ] Patrik Kleindl commented on KAFKA-5998: --- This issue was what led me to 

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

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

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

[ https://issues.apache.org/jira/browse/KAFKA-8173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16825808#comment-16825808 ] Arpit Khare commented on KAFKA-8173: [~regexcracker] This issue occurs because of corrupt index