[jira] [Commented] (KAFKA-8188) Zookeeper Connection Issue Take Down the Whole Kafka Cluster

[ https://issues.apache.org/jira/browse/KAFKA-8188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16811415#comment-16811415 ] Kartik commented on KAFKA-8188: --- [~candicewan] I see below JAAS config file missing error.

[jira] [Commented] (KAFKA-5636) DSL: allow sliding windows to be used directly (i.e. not just implicitly when doing joins)

[ https://issues.apache.org/jira/browse/KAFKA-5636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16811405#comment-16811405 ] ASF GitHub Bot commented on KAFKA-5636: --- ableegoldman commented on pull request #65

[jira] [Commented] (KAFKA-8168) Add a generated ApiMessageType class

[ https://issues.apache.org/jira/browse/KAFKA-8168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16811325#comment-16811325 ] ASF GitHub Bot commented on KAFKA-8168: --- gwenshap commented on pull request #6510:

[jira] [Resolved] (KAFKA-8168) Add a generated ApiMessageType class

[ https://issues.apache.org/jira/browse/KAFKA-8168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira resolved KAFKA-8168. - Resolution: Fixed Reviewer: Gwen Shapira Fix Version/s: 2.3.0 > Add a generated A

[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&focusedCommentId=16811320#comment-16811320 ] Mohan Parthasarathy commented on KAFKA-5998: This is becoming a real problem.

[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=16811243#comment-16811243 ] Guozhang Wang commented on KAFKA-7965: -- https://github.com/apache/kafka/pull/6238 is

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

[ https://issues.apache.org/jira/browse/KAFKA-7965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-7965: Assignee: huxihx (was: Stanislav Kozlovski) > Flaky Test > ConsumerBounceTest#testRollin

[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=16811242#comment-16811242 ] Guozhang Wang commented on KAFKA-7965: -- [~huxi_2b] Please feel free to submit a PR.

[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=16811241#comment-16811241 ] Guozhang Wang commented on KAFKA-7965: -- Another failure: {code} 12:19:11 kafka.api

[jira] [Commented] (KAFKA-8153) Streaming application with state stores takes up to 1 hour to restart

[ https://issues.apache.org/jira/browse/KAFKA-8153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16811237#comment-16811237 ] Guozhang Wang commented on KAFKA-8153: -- Hey [~mmelsen] what is `CleanupConfig` you m

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

Michael Drogalis created KAFKA-8198: --- Summary: KStreams testing docs use non-existent method "pipe" Key: KAFKA-8198 URL: https://issues.apache.org/jira/browse/KAFKA-8198 Project: Kafka Issu

[jira] [Commented] (KAFKA-8032) Flaky Test UserQuotaTest#testQuotaOverrideDelete

[ https://issues.apache.org/jira/browse/KAFKA-8032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16811233#comment-16811233 ] Guozhang Wang commented on KAFKA-8032: -- One more: {{java.lang.AssertionError: Client

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

[ https://issues.apache.org/jira/browse/KAFKA-8194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16811226#comment-16811226 ] Odyldzhon Toshbekov commented on KAFKA-8194: [~guozhang] thanks for your expl

[jira] [Commented] (KAFKA-7893) Refactor ConsumerBounceTest.scala

[ https://issues.apache.org/jira/browse/KAFKA-7893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16811221#comment-16811221 ] ASF GitHub Bot commented on KAFKA-7893: --- hachikuji commented on pull request #6238:

[jira] [Resolved] (KAFKA-7893) Refactor ConsumerBounceTest.scala

[ https://issues.apache.org/jira/browse/KAFKA-7893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7893. Resolution: Fixed > Refactor ConsumerBounceTest.scala > - >

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

[ https://issues.apache.org/jira/browse/KAFKA-8194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16811215#comment-16811215 ] Guozhang Wang commented on KAFKA-8194: -- AFAIK only when transactional messaging are

[jira] [Created] (KAFKA-8197) Flaky Test kafka.server.DynamicBrokerConfigTest > testPasswordConfigEncoderSecretChange

Guozhang Wang created KAFKA-8197: Summary: Flaky Test kafka.server.DynamicBrokerConfigTest > testPasswordConfigEncoderSecretChange Key: KAFKA-8197 URL: https://issues.apache.org/jira/browse/KAFKA-8197

[jira] [Commented] (KAFKA-6824) Flaky Test DynamicBrokerReconfigurationTest#testAddRemoveSslListener

[ https://issues.apache.org/jira/browse/KAFKA-6824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16811205#comment-16811205 ] Guozhang Wang commented on KAFKA-6824: -- Happened again: {code} 10:41:20 kafka.serve

[jira] [Commented] (KAFKA-8003) Flaky Test TransactionsTest #testFencingOnTransactionExpiration

[ https://issues.apache.org/jira/browse/KAFKA-8003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16811203#comment-16811203 ] Guozhang Wang commented on KAFKA-8003: -- Happened on 2.2 again: {code} 10:00:48 kafk

[jira] [Resolved] (KAFKA-8190) Keystore update without file change doesn't update SSLContext

[ https://issues.apache.org/jira/browse/KAFKA-8190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-8190. --- Resolution: Fixed Reviewer: Manikumar Fix Version/s: 2.3.0 > Keystore update

[jira] [Commented] (KAFKA-8190) Keystore update without file change doesn't update SSLContext

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

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

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

[jira] [Commented] (KAFKA-8196) Replace InitProducerId request/response with automated protocol

[ https://issues.apache.org/jira/browse/KAFKA-8196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16811081#comment-16811081 ] Mickael Maison commented on KAFKA-8196: --- Thanks [~omkreddy]!, I've reassigned it to

[jira] [Assigned] (KAFKA-8196) Replace InitProducerId request/response with automated protocol

[ https://issues.apache.org/jira/browse/KAFKA-8196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mickael Maison reassigned KAFKA-8196: - Assignee: Jason Gustafson (was: Mickael Maison) > Replace InitProducerId request/respon

[jira] [Commented] (KAFKA-8196) Replace InitProducerId request/response with automated protocol

[ https://issues.apache.org/jira/browse/KAFKA-8196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16811077#comment-16811077 ] Manikumar commented on KAFKA-8196: -- https://github.com/apache/kafka/pull/6538/ > Repla

[jira] [Created] (KAFKA-8196) Replace InitProducerId request/response with automated protocol

Mickael Maison created KAFKA-8196: - Summary: Replace InitProducerId request/response with automated protocol Key: KAFKA-8196 URL: https://issues.apache.org/jira/browse/KAFKA-8196 Project: Kafka

[jira] [Created] (KAFKA-8195) Unstable Producer After Send Failure in Transaction

Gary Russell created KAFKA-8195: --- Summary: Unstable Producer After Send Failure in Transaction Key: KAFKA-8195 URL: https://issues.apache.org/jira/browse/KAFKA-8195 Project: Kafka Issue Type: B

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

[ https://issues.apache.org/jira/browse/KAFKA-8194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16811042#comment-16811042 ] Odyldzhon Toshbekov commented on KAFKA-8194: [~guozhang], I didn't check it y

[jira] [Commented] (KAFKA-8187) State store record loss across multiple reassignments when using standby tasks

[ https://issues.apache.org/jira/browse/KAFKA-8187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16811023#comment-16811023 ] Guozhang Wang commented on KAFKA-8187: -- [~wgreerx] Thanks for reporting the bug! It

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

[ https://issues.apache.org/jira/browse/KAFKA-7983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16811005#comment-16811005 ] Jun Rao commented on KAFKA-7983: Probably. But I think the common broker level setting wi

[jira] [Commented] (KAFKA-7904) KIP-427: Add AtMinIsr topic partition category (new metric & TopicCommand option)

[ https://issues.apache.org/jira/browse/KAFKA-7904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16810995#comment-16810995 ] ASF GitHub Bot commented on KAFKA-7904: --- gwenshap commented on pull request #6421:

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

[ https://issues.apache.org/jira/browse/KAFKA-8157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16810992#comment-16810992 ] Guozhang Wang commented on KAFKA-8157: -- I can confirm that this fix is piggy-backed

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

[ https://issues.apache.org/jira/browse/KAFKA-8194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16810977#comment-16810977 ] Guozhang Wang commented on KAFKA-8194: -- [~odyldz...@gmail.com] do you know why the m

[jira] [Commented] (KAFKA-7192) State-store can desynchronise with changelog

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

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

[ https://issues.apache.org/jira/browse/KAFKA-8194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Odyldzhon Toshbekov updated KAFKA-8194: --- Description: Looks like metric {code:java} kafka.server:type=BrokerTopicMetrics,name=

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

[ https://issues.apache.org/jira/browse/KAFKA-8194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Odyldzhon Toshbekov updated KAFKA-8194: --- Description: Looks like metric {code:java}kafka.server:type=BrokerTopicMetrics,name=M

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

Odyldzhon Toshbekov created KAFKA-8194: -- Summary: MessagesInPerSec incorrect value when Stream produce messages Key: KAFKA-8194 URL: https://issues.apache.org/jira/browse/KAFKA-8194 Project: Kafk

[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=16810770#comment-16810770 ] Andrew Klopper commented on KAFKA-7895: --- Hi John Roesler I can confirm that I am n

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

[ https://issues.apache.org/jira/browse/KAFKA-7983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16810715#comment-16810715 ] huxihx commented on KAFKA-7983: --- If specified at broker level, should them follow the forma

[jira] [Commented] (KAFKA-6582) Partitions get underreplicated, with a single ISR, and doesn't recover. Other brokers do not take over and we need to manually restart the broker.

[ https://issues.apache.org/jira/browse/KAFKA-6582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16810713#comment-16810713 ] Jonathan Santilli commented on KAFKA-6582: -- Hello [~pogo] we are facing the same

[jira] [Commented] (KAFKA-8154) Buffer Overflow exceptions between brokers and with clients

[ https://issues.apache.org/jira/browse/KAFKA-8154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16810562#comment-16810562 ] ASF GitHub Bot commented on KAFKA-8154: --- Spatterjaaay commented on pull request #65

[jira] [Commented] (KAFKA-8154) Buffer Overflow exceptions between brokers and with clients

[ https://issues.apache.org/jira/browse/KAFKA-8154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16810551#comment-16810551 ] ASF GitHub Bot commented on KAFKA-8154: --- Spatterjaaay commented on pull request #65