[jira] [Commented] (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:comment-tabpanel&focusedCommentId=16798770#comment-16798770 ] ASF GitHub Bot commented on KAFKA-8142: --- mjsax commented on pull request #6484: KAF

[jira] [Created] (KAFKA-8144) Flaky Test ControllerIntegrationTest#testMetadataPropagationOnControlPlane

Matthias J. Sax created KAFKA-8144: -- Summary: Flaky Test ControllerIntegrationTest#testMetadataPropagationOnControlPlane Key: KAFKA-8144 URL: https://issues.apache.org/jira/browse/KAFKA-8144 Project:

[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&focusedCommentId=16798695#comment-16798695 ] Shengnan YU commented on KAFKA-8100: Thanks for replying. However if the topic is per

[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&focusedCommentId=16798686#comment-16798686 ] huxihx commented on KAFKA-8100: --- Since `UNKNOWN_TOPIC_OR_PARTITION` is a retriable exceptio

[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&focusedCommentId=16798598#comment-16798598 ] Matthias J. Sax commented on KAFKA-7647: Failed again: [https://builds.apache.org

[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&focusedCommentId=16798585#comment-16798585 ] Matthias J. Sax commented on KAFKA-8042: [~ableegoldman] From my understanding, t

[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&focusedCommentId=16798581#comment-16798581 ] Guozhang Wang commented on KAFKA-7243: -- [~Khairy] Thanks for your contribution! > A

[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 duplicat

[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&focusedCommentId=16798580#comment-16798580 ] ASF GitHub Bot commented on KAFKA-7243: --- guozhangwang commented on pull request #60

[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&focusedCommentId=16798577#comment-16798577 ] Matthias J. Sax commented on KAFKA-7965: [https://builds.apache.org/blue/organiza

[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&focusedCommentId=16798573#comment-16798573 ] Tommy Becker commented on KAFKA-8143: - I think this is possibly due to https://issue

[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&focusedCommentId=16798572#comment-16798572 ] Matthias J. Sax commented on KAFKA-7965: [https://builds.apache.org/blue/organiza

[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&focusedCommentId=16798528#comment-16798528 ] Matthias J. Sax commented on KAFKA-7996: How would this config and `KafakStreams#

[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&focusedCommentId=16798477#comment-16798477 ] Sophie Blee-Goldman commented on KAFKA-8042: I think KAFKA-7934 would certain

[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&focusedCommentId=16798432#comment-16798432 ] Matthias J. Sax commented on KAFKA-8042: Is this different to KAFKA-7934 or a dup

[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 St

[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&focusedCommentId=16798309#comment-16798309 ] ASF GitHub Bot commented on KAFKA-8142: --- mjsax commented on pull request #6484: KAF

[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 null-valu

[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: Kafk

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

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

[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&focusedCommentId=16798210#comment-16798210 ] Lee Dongjin commented on KAFKA-7996: [~bbejeck] Great. I will prepare the KIP. Thanks

[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&focusedCommentId=16798017#comment-16798017 ] Andrew Klopper edited comment on KAFKA-7895 at 3/21/19 11:38 AM: --

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

[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 > RequestQuotaTest#testRespon

[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 > RequestQuotaTest#testRespons

[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&focusedCommentId=16797963#comment-16797963 ] ASF GitHub Bot commented on KAFKA-7989: --- rajinisivaram commented on pull request #6

[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&focusedCommentId=16797927#comment-16797927 ] Flower.min commented on KAFKA-8106: --- _*We only don't decompress key and value of a reco