[jira] [Commented] (KAFKA-8044) System Test Failure: ReassignPartitionsTest.test_reassign_partitions

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

[jira] [Commented] (KAFKA-7502) Cleanup KTable materialization logic in a single place

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

[jira] [Commented] (KAFKA-8111) KafkaProducer can't produce data

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

[jira] [Commented] (KAFKA-8114) Flaky Test DelegationTokenEndToEndAuthorizationTest#testNoGroupAcl

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

[jira] [Commented] (KAFKA-8118) Ensure that tests close ZooKeeper clients since they can impact subsequent tests

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

[jira] [Commented] (KAFKA-8119) KafkaConfig listener accessors may fail during dynamic update

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

[jira] [Commented] (KAFKA-8026) Flaky Test RegexSourceIntegrationTest#testRegexMatchesTopicsAWhenDeleted

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

[jira] [Commented] (KAFKA-7813) JmxTool throws NPE when --object-name is omitted

[ https://issues.apache.org/jira/browse/KAFKA-7813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16794646#comment-16794646 ] ASF GitHub Bot commented on KAFKA-7813: --- ewencp commented on pull request #6139: KA

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=16794667#comment-16794667 ] ASF GitHub Bot commented on KAFKA-3729: --- tedyu commented on pull request #6461: [KA

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=16794668#comment-16794668 ] ASF GitHub Bot commented on KAFKA-3729: --- tedyu commented on pull request #6399: [KA

[jira] [Commented] (KAFKA-8118) Ensure that tests close ZooKeeper clients since they can impact subsequent tests

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

[jira] [Commented] (KAFKA-8121) ZooKeeperClient session expiry thread may leave clients behind after close

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

[jira] [Commented] (KAFKA-8026) Flaky Test RegexSourceIntegrationTest#testRegexMatchesTopicsAWhenDeleted

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

[jira] [Commented] (KAFKA-8121) ZooKeeperClient session expiry thread may leave clients behind after close

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

[jira] [Commented] (KAFKA-7858) Replace JoinGroup request/response with automated protocol

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

[jira] [Commented] (KAFKA-8062) StateListener is not notified when StreamThread dies

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

[jira] [Commented] (KAFKA-8127) It may need to import scala.io

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

[jira] [Commented] (KAFKA-8127) It may need to import scala.io

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

[jira] [Commented] (KAFKA-8062) StateListener is not notified when StreamThread dies

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

[jira] [Commented] (KAFKA-8094) Iterating over cache with get(key) is inefficient

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

[jira] [Commented] (KAFKA-6958) Allow to define custom processor names with KStreams DSL

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

[jira] [Commented] (KAFKA-8125) Check for topic existence in CreateTopicsRequest prior to creating replica assignment

[ https://issues.apache.org/jira/browse/KAFKA-8125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16796730#comment-16796730 ] ASF GitHub Bot commented on KAFKA-8125: --- huxihx commented on pull request #6472: KA

[jira] [Commented] (KAFKA-8098) Flaky Test AdminClientIntegrationTest#testConsumerGroups

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

[jira] [Commented] (KAFKA-8130) The consumer is not closed in GetOffsetShell, will exhausted socket channel when frequent calls

[ https://issues.apache.org/jira/browse/KAFKA-8130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16796874#comment-16796874 ] ASF GitHub Bot commented on KAFKA-8130: --- Mrart commented on pull request #6473: KAF

[jira] [Commented] (KAFKA-8098) Flaky Test AdminClientIntegrationTest#testConsumerGroups

[ https://issues.apache.org/jira/browse/KAFKA-8098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16796973#comment-16796973 ] ASF GitHub Bot commented on KAFKA-8098: --- huxihx commented on pull request #6474: me

[jira] [Commented] (KAFKA-8126) Flaky Test org.apache.kafka.connect.runtime.WorkerTest.testAddRemoveTask

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

[jira] [Commented] (KAFKA-8098) Flaky Test AdminClientIntegrationTest#testConsumerGroups

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

[jira] [Commented] (KAFKA-7723) Kafka Connect support override worker kafka api configuration with connector configuration that post by rest api

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

[jira] [Commented] (KAFKA-8131) Add --version parameter to command line help outputs & docs

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

[jira] [Commented] (KAFKA-8131) Add --version parameter to command line help outputs & docs

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

[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=16797874#comment-16797874 ] ASF GitHub Bot commented on KAFKA-7989: --- apovzner commented on pull request #6482:

[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-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-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] [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-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] [Commented] (KAFKA-8150) Fix bugs in handling null arrays in generated RPC code

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

[jira] [Commented] (KAFKA-7986) distinguish the logging from different ZooKeeperClient instances

[ https://issues.apache.org/jira/browse/KAFKA-7986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16799761#comment-16799761 ] ASF GitHub Bot commented on KAFKA-7986: --- ivanyu commented on pull request #6493: KA

[jira] [Commented] (KAFKA-6820) Improve on StreamsMetrics Public APIs

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

[jira] [Commented] (KAFKA-8026) Flaky Test RegexSourceIntegrationTest#testRegexMatchesTopicsAWhenDeleted

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

[jira] [Commented] (KAFKA-8150) Fix bugs in handling null arrays in generated RPC code

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

[jira] [Commented] (KAFKA-8102) Trogdor - Add Produce workload transaction generator by interval

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

[jira] [Commented] (KAFKA-6988) Kafka windows classpath too long

[ https://issues.apache.org/jira/browse/KAFKA-6988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16800922#comment-16800922 ] ASF GitHub Bot commented on KAFKA-6988: --- ward-eric commented on pull request #6499:

[jira] [Commented] (KAFKA-8026) Flaky Test RegexSourceIntegrationTest#testRegexMatchesTopicsAWhenDeleted

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

[jira] [Commented] (KAFKA-7986) distinguish the logging from different ZooKeeperClient instances

[ https://issues.apache.org/jira/browse/KAFKA-7986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16801307#comment-16801307 ] ASF GitHub Bot commented on KAFKA-7986: --- junrao commented on pull request #6493: KA

[jira] [Commented] (KAFKA-8134) ProducerConfig.LINGER_MS_CONFIG undocumented breaking change in kafka-clients 2.1

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

[jira] [Commented] (KAFKA-8158) Add EntityType for Kafka RPC fields

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

[jira] [Commented] (KAFKA-3522) Consider adding version information into rocksDB storage format

[ https://issues.apache.org/jira/browse/KAFKA-3522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16802191#comment-16802191 ] ASF GitHub Bot commented on KAFKA-3522: --- mjsax commented on pull request #6186: KAF

[jira] [Commented] (KAFKA-8030) Flaky Test TopicCommandWithAdminClientTest#testDescribeUnderMinIsrPartitionsMixed

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

[jira] [Commented] (KAFKA-8164) Improve test passing rate by rerunning flaky tests

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

[jira] [Commented] (KAFKA-6399) Consider reducing "max.poll.interval.ms" default for Kafka Streams

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

[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=16803382#comment-16803382 ] ASF GitHub Bot commented on KAFKA-8168: --- cmccabe commented on pull request #6510: K

[jira] [Commented] (KAFKA-7190) Under low traffic conditions purging repartition topics cause WARN statements about UNKNOWN_PRODUCER_ID

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

[jira] [Commented] (KAFKA-7981) Add Replica Fetcher and Log Cleaner Count Metrics

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

[jira] [Commented] (KAFKA-6983) Error while deleting segments - The process cannot access the file because it is being used by another process

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

[jira] [Commented] (KAFKA-7502) Cleanup KTable materialization logic in a single place

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

[jira] [Commented] (KAFKA-7502) Cleanup KTable materialization logic in a single place

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

[jira] [Commented] (KAFKA-7502) Cleanup KTable materialization logic in a single place

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

[jira] [Commented] (KAFKA-8175) The broker block some minutes may occur expired error message for a period of time

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

[jira] [Commented] (KAFKA-8162) IBM JDK Class not found error when handling SASL authentication exception

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

[jira] [Commented] (KAFKA-7502) Cleanup KTable materialization logic in a single place

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

[jira] [Commented] (KAFKA-7502) Cleanup KTable materialization logic in a single place

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

[jira] [Commented] (KAFKA-8034) Replace DeleteTopics request/response with automated protocol

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

[jira] [Commented] (KAFKA-8029) Add in-memory bytes-only session store implementation

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

[jira] [Commented] (KAFKA-8030) Flaky Test TopicCommandWithAdminClientTest#testDescribeUnderMinIsrPartitionsMixed

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

[jira] [Commented] (KAFKA-7828) Execute Trogdor tasks with external commands

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

[jira] [Commented] (KAFKA-8181) Streams docs on serialization include Avro header, but no content

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

[jira] [Commented] (KAFKA-8179) Incremental Rebalance Protocol for Kafka Consumer

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

[jira] [Commented] (KAFKA-8181) Streams docs on serialization include Avro header, but no content

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

[jira] [Commented] (KAFKA-8183) Trogdor - ProduceBench should retry on UnknownTopicOrPartitionException during topic creation

[ https://issues.apache.org/jira/browse/KAFKA-8183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16808043#comment-16808043 ] ASF GitHub Bot commented on KAFKA-8183: --- stanislavkozlovski commented on pull reque

[jira] [Commented] (KAFKA-8183) Trogdor - ProduceBench should retry on UnknownTopicOrPartitionException during topic creation

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

[jira] [Commented] (KAFKA-7190) Under low traffic conditions purging repartition topics cause WARN statements about UNKNOWN_PRODUCER_ID

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

[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=16808817#comment-16808817 ] ASF GitHub Bot commented on KAFKA-8157: --- ouertani commented on pull request #6535:

[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=16808896#comment-16808896 ] ASF GitHub Bot commented on KAFKA-7895: --- vvcephei commented on pull request #6536:

[jira] [Commented] (KAFKA-8126) Flaky Test org.apache.kafka.connect.runtime.WorkerTest.testAddRemoveTask

[ https://issues.apache.org/jira/browse/KAFKA-8126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16809166#comment-16809166 ] ASF GitHub Bot commented on KAFKA-8126: --- rhauch commented on pull request #6475: KA

[jira] [Commented] (KAFKA-6399) Consider reducing "max.poll.interval.ms" default for Kafka Streams

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

[jira] [Commented] (KAFKA-8090) Replace ControlledShutdown request/response with automated protocol

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

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

[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

[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-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] [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=16811103#comment-16811103 ] ASF GitHub Bot commented on KAFKA-8157: --- guozhangwang commented on pull request #65

[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-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] [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] [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-8058) ConnectRestExtensionContext does not return list of connectors from its ConnectClusterState

[ https://issues.apache.org/jira/browse/KAFKA-8058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16811902#comment-16811902 ] ASF GitHub Bot commented on KAFKA-8058: --- rhauch commented on pull request #6384: KA

[jira] [Commented] (KAFKA-7841) KIP-419 Safely notify Kafka Connect SourceTask is stopped

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

[jira] [Commented] (KAFKA-8013) Avoid buffer underflow when reading a Struct from a partially correct buffer

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

[jira] [Commented] (KAFKA-8204) Streams may flush state stores in the incorrect order

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

[jira] [Commented] (KAFKA-8200) TopologyTestDriver should offer an iterable signature of readOutput

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

[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=16814015#comment-16814015 ] ASF GitHub Bot commented on KAFKA-7965: --- huxihx commented on pull request #6557: KA

[jira] [Commented] (KAFKA-8215) Limit memory usage of RocksDB

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

[jira] [Commented] (KAFKA-8211) Flaky Test: ResetConsumerGroupOffsetTest.testResetOffsetsExportImportPlan

[ https://issues.apache.org/jira/browse/KAFKA-8211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16815064#comment-16815064 ] ASF GitHub Bot commented on KAFKA-8211: --- huxihx commented on pull request #6561: KA

[jira] [Commented] (KAFKA-8208) Broken link for out-of-order data in KStreams Core Concepts doc

[ https://issues.apache.org/jira/browse/KAFKA-8208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16815749#comment-16815749 ] ASF GitHub Bot commented on KAFKA-8208: --- bbejeck commented on pull request #197: KA

[jira] [Commented] (KAFKA-8209) Wrong link for KStreams DSL in Core Concepts doc

[ https://issues.apache.org/jira/browse/KAFKA-8209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16815770#comment-16815770 ] ASF GitHub Bot commented on KAFKA-8209: --- bbejeck commented on pull request #198: KA

[jira] [Commented] (KAFKA-8209) Wrong link for KStreams DSL in Core Concepts doc

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

[jira] [Commented] (KAFKA-6455) Improve timestamp propagation at DSL level

[ https://issues.apache.org/jira/browse/KAFKA-6455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16815795#comment-16815795 ] ASF GitHub Bot commented on KAFKA-6455: --- mjsax commented on pull request #6565: KAF

[jira] [Commented] (KAFKA-7601) Handle message format downgrades during upgrade of message format version

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

  1   2   3   4   5   6   7   8   9   10   >