[jira] [Commented] (KAFKA-8100) If delete expired topic, kafka consumer will keep flushing unknown_topic warning in log

[ https://issues.apache.org/jira/browse/KAFKA-8100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16798695#comment-16798695 ] Shengnan YU commented on KAFKA-8100: Thanks for replying. However if the topic is permanent deleted,

[jira] [Commented] (KAFKA-8100) If delete expired topic, kafka consumer will keep flushing unknown_topic warning in log

[ https://issues.apache.org/jira/browse/KAFKA-8100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16798686#comment-16798686 ] huxihx commented on KAFKA-8100: --- Since `UNKNOWN_TOPIC_OR_PARTITION` is a retriable exception, it's hard to

[jira] [Commented] (KAFKA-7647) Flaky test LogCleanerParameterizedIntegrationTest.testCleansCombinedCompactAndDeleteTopic

[ https://issues.apache.org/jira/browse/KAFKA-7647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16798598#comment-16798598 ] Matthias J. Sax commented on KAFKA-7647: Failed again:

[jira] [Commented] (KAFKA-8042) Kafka Streams creates many segment stores on state restore

[ https://issues.apache.org/jira/browse/KAFKA-8042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16798585#comment-16798585 ] Matthias J. Sax commented on KAFKA-8042: [~ableegoldman] From my understanding, the fast

[jira] [Commented] (KAFKA-7243) Add unit integration tests to validate metrics in Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16798581#comment-16798581 ] Guozhang Wang commented on KAFKA-7243: -- [~Khairy] Thanks for your contribution! > Add unit

[jira] [Resolved] (KAFKA-8143) Kafka-Streams GlobalStore cannot be read after application restart

[ https://issues.apache.org/jira/browse/KAFKA-8143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-8143. Resolution: Duplicate Thanks for reporting this [~lukestephenson]! Closing this as

[jira] [Commented] (KAFKA-7243) Add unit integration tests to validate metrics in Kafka Streams

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

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

[ https://issues.apache.org/jira/browse/KAFKA-7965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16798577#comment-16798577 ] Matthias J. Sax commented on KAFKA-7965:

[jira] [Commented] (KAFKA-8143) Kafka-Streams GlobalStore cannot be read after application restart

[ https://issues.apache.org/jira/browse/KAFKA-8143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16798573#comment-16798573 ] Tommy Becker commented on KAFKA-8143: - I think this is possibly due to

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

[ https://issues.apache.org/jira/browse/KAFKA-7965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16798572#comment-16798572 ] Matthias J. Sax commented on KAFKA-7965:

[jira] [Updated] (KAFKA-8143) Kafka-Streams GlobalStore cannot be read after application restart

[ https://issues.apache.org/jira/browse/KAFKA-8143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Stephenson updated KAFKA-8143: --- Description: I've created a small example application which has a trivial `Processor` which

[jira] [Created] (KAFKA-8143) Kafka-Streams GlobalStore cannot be read after application restart

Luke Stephenson created KAFKA-8143: -- Summary: Kafka-Streams GlobalStore cannot be read after application restart Key: KAFKA-8143 URL: https://issues.apache.org/jira/browse/KAFKA-8143 Project: Kafka

[jira] [Commented] (KAFKA-7996) KafkaStreams does not pass timeout when closing Producer

[ https://issues.apache.org/jira/browse/KAFKA-7996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16798528#comment-16798528 ] Matthias J. Sax commented on KAFKA-7996: How would this config and `KafakStreams#close(timeout)`

[jira] [Commented] (KAFKA-8042) Kafka Streams creates many segment stores on state restore

[ https://issues.apache.org/jira/browse/KAFKA-8042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16798477#comment-16798477 ] Sophie Blee-Goldman commented on KAFKA-8042: I think KAFKA-7934 would certainly fix this

[jira] [Commented] (KAFKA-8042) Kafka Streams creates many segment stores on state restore

[ https://issues.apache.org/jira/browse/KAFKA-8042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16798432#comment-16798432 ] Matthias J. Sax commented on KAFKA-8042: Is this different to KAFKA-7934 or a duplicate? > Kafka

[jira] [Updated] (KAFKA-8142) Kafka Streams fails with NPE if record contains null-value in header

[ https://issues.apache.org/jira/browse/KAFKA-8142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8142: --- Summary: Kafka Streams fails with NPE if record contains null-value in header (was: Kafka

[jira] [Commented] (KAFKA-8142) Kafka Streams fails with NPE if records contains null-value in header

[ https://issues.apache.org/jira/browse/KAFKA-8142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16798309#comment-16798309 ] ASF GitHub Bot commented on KAFKA-8142: --- mjsax commented on pull request #6484: KAFKA-8142: Fix NPE

[jira] [Assigned] (KAFKA-8142) Kafka Streams fails with NPE if records contains null-value in header

[ https://issues.apache.org/jira/browse/KAFKA-8142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-8142: -- Assignee: Matthias J. Sax > Kafka Streams fails with NPE if records contains

[jira] [Created] (KAFKA-8142) Kafka Streams fails with NPE if records contains null-value in header

Matthias J. Sax created KAFKA-8142: -- Summary: Kafka Streams fails with NPE if records contains null-value in header Key: KAFKA-8142 URL: https://issues.apache.org/jira/browse/KAFKA-8142 Project:

[jira] [Commented] (KAFKA-7819) Trogdor - Improve RoundTripWorker

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

[jira] [Commented] (KAFKA-7996) KafkaStreams does not pass timeout when closing Producer

[ https://issues.apache.org/jira/browse/KAFKA-7996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16798210#comment-16798210 ] Lee Dongjin commented on KAFKA-7996: [~bbejeck] Great. I will prepare the KIP. Thanks for your

[jira] [Comment Edited] (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=16798017#comment-16798017 ] Andrew Klopper edited comment on KAFKA-7895 at 3/21/19 11:38 AM: - Hi I

[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=16798017#comment-16798017 ] Andrew Klopper commented on KAFKA-7895: --- Hi I am still seeing this behaviour using the 2.2.0 Maven

[jira] [Resolved] (KAFKA-8123) Flaky Test RequestQuotaTest#testResponseThrottleTimeWhenBothProduceAndRequestQuotasViolated

[ https://issues.apache.org/jira/browse/KAFKA-8123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-8123. --- Resolution: Duplicate Fix Version/s: 2.2.1 > Flaky Test >

[jira] [Resolved] (KAFKA-7989) Flaky Test RequestQuotaTest#testResponseThrottleTimeWhenBothFetchAndRequestQuotasViolated

[ https://issues.apache.org/jira/browse/KAFKA-7989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-7989. --- Resolution: Fixed Reviewer: Rajini Sivaram > Flaky Test >

[jira] [Commented] (KAFKA-7989) Flaky Test RequestQuotaTest#testResponseThrottleTimeWhenBothFetchAndRequestQuotasViolated

[ https://issues.apache.org/jira/browse/KAFKA-7989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16797963#comment-16797963 ] ASF GitHub Bot commented on KAFKA-7989: --- rajinisivaram commented on pull request #6482: KAFKA-7989:

[jira] [Commented] (KAFKA-8106) Remove unnecessary decompression operation when logValidator do validation.

[ https://issues.apache.org/jira/browse/KAFKA-8106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16797927#comment-16797927 ] Flower.min commented on KAFKA-8106: --- _*We only don't decompress key and value of a record, it still can

[jira] [Commented] (KAFKA-7989) Flaky Test RequestQuotaTest#testResponseThrottleTimeWhenBothFetchAndRequestQuotasViolated

[ https://issues.apache.org/jira/browse/KAFKA-7989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16797874#comment-16797874 ] ASF GitHub Bot commented on KAFKA-7989: --- apovzner commented on pull request #6482: KAFKA-7989: