[jira] [Commented] (KAFKA-6647) KafkaStreams.cleanUp creates .lock file in directory its trying to clean (Windows OS)

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

[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&focusedCommentId=16816120#comment-16816120 ] ASF GitHub Bot commented on KAFKA-7866: --- hachikuji commented on pull request #6570:

[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=16816380#comment-16816380 ] ASF GitHub Bot commented on KAFKA-8208: --- bbejeck commented on pull request #6572: K

[jira] [Commented] (KAFKA-8210) Missing link for KStreams in Streams DSL docs

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

[jira] [Commented] (KAFKA-8210) Missing link for KStreams in Streams DSL docs

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

[jira] [Commented] (KAFKA-8213) KStreams interactive query documentation typo

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

[jira] [Commented] (KAFKA-8212) KStreams documentation Maven artifact table is cut off

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

[jira] [Commented] (KAFKA-8212) KStreams documentation Maven artifact table is cut off

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

[jira] [Commented] (KAFKA-8213) KStreams interactive query documentation typo

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

[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=16816774#comment-16816774 ] ASF GitHub Bot commented on KAFKA-5636: --- ableegoldman commented on pull request #65

[jira] [Commented] (KAFKA-8213) KStreams interactive query documentation typo

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

[jira] [Commented] (KAFKA-8213) KStreams interactive query documentation typo

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

[jira] [Commented] (KAFKA-8212) KStreams documentation Maven artifact table is cut off

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

[jira] [Commented] (KAFKA-8212) KStreams documentation Maven artifact table is cut off

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

[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=16817114#comment-16817114 ] ASF GitHub Bot commented on KAFKA-8209: --- bbejeck commented on pull request #6564: K

[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=16817125#comment-16817125 ] ASF GitHub Bot commented on KAFKA-8209: --- bbejeck commented on pull request #198: KA

[jira] [Commented] (KAFKA-8210) Missing link for KStreams in Streams DSL docs

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

[jira] [Commented] (KAFKA-8210) Missing link for KStreams in Streams DSL docs

[ https://issues.apache.org/jira/browse/KAFKA-8210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16817129#comment-16817129 ] ASF GitHub Bot commented on KAFKA-8210: --- bbejeck commented on pull request #199: 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=16817130#comment-16817130 ] ASF GitHub Bot commented on KAFKA-8208: --- bbejeck commented on pull request #197: 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=16817131#comment-16817131 ] ASF GitHub Bot commented on KAFKA-8208: --- bbejeck commented on pull request #6572: K

[jira] [Commented] (KAFKA-8229) Connect Sink Task updates nextCommit when commitRequest is true

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

[jira] [Commented] (KAFKA-8152) Offline partition state not propagated by controller

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

[jira] [Commented] (KAFKA-8232) Flaky test kafka.admin.TopicCommandWithAdminClientTest.testTopicDeletion

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

[jira] [Commented] (KAFKA-8052) Intermittent INVALID_FETCH_SESSION_EPOCH error on FETCH request

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

[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&focusedCommentId=16817560#comment-16817560 ] ASF GitHub Bot commented on KAFKA-7903: --- abbccdda commented on pull request #6583:

[jira] [Commented] (KAFKA-8232) Flaky test kafka.admin.TopicCommandWithAdminClientTest.testTopicDeletion

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

[jira] [Commented] (KAFKA-8231) Expansion of ConnectClusterState interface

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

[jira] [Commented] (KAFKA-6635) Producer close does not await pending transaction

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

[jira] [Commented] (KAFKA-7778) Add KTable.suppress to Scala API

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

[jira] [Commented] (KAFKA-7471) Multiple Consumer Group Management (Describe, Reset, Delete)

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

[jira] [Commented] (KAFKA-8241) Dynamic update of keystore fails on listener without truststore

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

[jira] [Commented] (KAFKA-7778) Add KTable.suppress to Scala API

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

[jira] [Commented] (KAFKA-7875) Add KStream#flatTransformValues

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

[jira] [Commented] (KAFKA-7778) Add KTable.suppress to Scala API

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

[jira] [Commented] (KAFKA-8152) Offline partition state not propagated by controller

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

[jira] [Commented] (KAFKA-7466) Implement KIP-339: Create a new IncrementalAlterConfigs API

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

[jira] [Commented] (KAFKA-8237) Untangle TopicDeletionManager and add test cases

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

[jira] [Commented] (KAFKA-8240) Source.equals() can fail with NPE

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

[jira] [Commented] (KAFKA-6647) KafkaStreams.cleanUp creates .lock file in directory its trying to clean (Windows OS)

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

[jira] [Commented] (KAFKA-6647) KafkaStreams.cleanUp creates .lock file in directory its trying to clean (Windows OS)

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

[jira] [Commented] (KAFKA-6647) KafkaStreams.cleanUp creates .lock file in directory its trying to clean (Windows OS)

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

[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=16820247#comment-16820247 ] ASF GitHub Bot commented on KAFKA-6455: --- mjsax commented on pull request #6565: KAF

[jira] [Commented] (KAFKA-8241) Dynamic update of keystore fails on listener without truststore

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

[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=16820353#comment-16820353 ] ASF GitHub Bot commented on KAFKA-8215: --- ableegoldman commented on pull request #65

[jira] [Commented] (KAFKA-8025) Flaky Test RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsAdapterTest#shouldForwardAllDbOptionsCalls

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

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

[jira] [Commented] (KAFKA-8147) Add changelog topic configuration to KTable suppress

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

[jira] [Commented] (KAFKA-6520) When a Kafka Stream can't communicate with the server, it's Status stays RUNNING

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

[jira] [Commented] (KAFKA-7652) Kafka Streams Session store performance degradation from 0.10.2.2 to 0.11.0.0

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

[jira] [Commented] (KAFKA-8155) Update Streams system tests for 2.2.0 and 2.1.1 releases

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

[jira] [Commented] (KAFKA-8155) Update Streams system tests for 2.2.0 and 2.1.1 releases

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

[jira] [Commented] (KAFKA-7026) Sticky assignor could assign a partition to multiple consumers (KIP-341)

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

[jira] [Commented] (KAFKA-8254) Suppress incorrectly passes a null topic to the serdes

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

[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&focusedCommentId=16821238#comment-16821238 ] ASF GitHub Bot commented on KAFKA-7866: --- hachikuji commented on pull request #6570:

[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=16821548#comment-16821548 ] ASF GitHub Bot commented on KAFKA-6958: --- bbejeck commented on pull request #6410: K

[jira] [Commented] (KAFKA-8248) Producer may fail IllegalStateException

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

[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=16821626#comment-16821626 ] ASF GitHub Bot commented on KAFKA-7965: --- hachikuji commented on pull request #6608:

[jira] [Commented] (KAFKA-8259) Build RPM for Kafka

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

[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=16822261#comment-16822261 ] ASF GitHub Bot commented on KAFKA-7965: --- gwenshap commented on pull request #6608:

[jira] [Commented] (KAFKA-8248) Producer may fail IllegalStateException

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

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

[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=16822540#comment-16822540 ] ASF GitHub Bot commented on KAFKA-3729: --- mjsax commented on pull request #6461: [KA

[jira] [Commented] (KAFKA-7747) Consumer should check for truncation after leader changes

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

[jira] [Commented] (KAFKA-8271) Trogdor - Log Jetty requests at DEBUG level

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

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

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

[jira] [Commented] (KAFKA-8275) NetworkClient leastLoadedNode selection should consider throttled nodes

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

[jira] [Commented] (KAFKA-8277) Fix NPE in ConnectHeaders

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

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

[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=16823589#comment-16823589 ] ASF GitHub Bot commented on KAFKA-7895: --- bbejeck commented on pull request #6615: K

[jira] [Commented] (KAFKA-5929) Save pre-assignment to file to avoid too long text to display when do topic partition reassign

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

[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=16824371#comment-16824371 ] ASF GitHub Bot commented on KAFKA-8204: --- vvcephei commented on pull request #6623:

[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=16824376#comment-16824376 ] ASF GitHub Bot commented on KAFKA-7895: --- bbejeck commented on pull request #6616: K

[jira] [Commented] (KAFKA-8227) Missing Links in Duality of Streams and Tables section

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

[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=16824707#comment-16824707 ] ASF GitHub Bot commented on KAFKA-8204: --- guozhangwang commented on pull request #66

[jira] [Commented] (KAFKA-8227) Missing Links in Duality of Streams and Tables section

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

[jira] [Commented] (KAFKA-8227) Missing Links in Duality of Streams and Tables section

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

[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=16825574#comment-16825574 ] ASF GitHub Bot commented on KAFKA-3729: --- mjsax commented on pull request #6630: KAF

[jira] [Commented] (KAFKA-6819) Refactor build-in StreamsMetrics internal implementations

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

[jira] [Commented] (KAFKA-8285) Handle thread-id random switch on JVM for KStream

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

[jira] [Commented] (KAFKA-8237) Untangle TopicDeletionManager and add test cases

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

[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&focusedCommentId=16826326#comment-16826326 ] ASF GitHub Bot commented on KAFKA-8290: --- bbejeck commented on pull request #6636: K

[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&focusedCommentId=16826536#comment-16826536 ] ASF GitHub Bot commented on KAFKA-7903: --- cmccabe commented on pull request #6583: K

[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=16826720#comment-16826720 ] ASF GitHub Bot commented on KAFKA-8200: --- pkleindl commented on pull request #6556:

[jira] [Commented] (KAFKA-8254) Suppress incorrectly passes a null topic to the serdes

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

[jira] [Commented] (KAFKA-8254) Suppress incorrectly passes a null topic to the serdes

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

[jira] [Commented] (KAFKA-8294) Batch StopReplica requests with partition deletion and add test cases

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

[jira] [Commented] (KAFKA-7862) Modify JoinGroup logic to incorporate group.instance.id change

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

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

[jira] [Commented] (KAFKA-8298) ConcurrentModificationException Possible when optimizing for repartition nodes

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

[jira] [Commented] (KAFKA-8254) Suppress incorrectly passes a null topic to the serdes

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

[jira] [Commented] (KAFKA-8299) Add type-safe instantiation of generic classes to AbstractConfig

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

[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=16827963#comment-16827963 ] ASF GitHub Bot commented on KAFKA-6455: --- mjsax commented on pull request #6645: KAF

[jira] [Commented] (KAFKA-7779) Avoid unnecessary loop iteration in leastLoadedNode

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

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

[jira] [Commented] (KAFKA-8225) handle conflicting static member id

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

[jira] [Commented] (KAFKA-8304) Connect susceptible to deadlock while registering REST extensions

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

[jira] [Commented] (KAFKA-8306) Ensure consistency of checkpointed log start offset and current log end offset

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

[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&focusedCommentId=16830577#comment-16830577 ] ASF GitHub Bot commented on KAFKA-8289: --- vvcephei commented on pull request #6654:

[jira] [Commented] (KAFKA-5117) Kafka Connect REST endpoints reveal Password typed values

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

<    1   2   3   4   5   6   7   8   9   10   >