[jira] [Commented] (KAFKA-4486) Kafka Streams - exception in process still commits offsets

[ https://issues.apache.org/jira/browse/KAFKA-4486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15729122#comment-15729122 ] ASF GitHub Bot commented on KAFKA-4486: --- GitHub user enothereska opened a pull reque

[jira] [Commented] (KAFKA-4503) Expose the log dir for a partition as a metric

[ https://issues.apache.org/jira/browse/KAFKA-4503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15729150#comment-15729150 ] ASF GitHub Bot commented on KAFKA-4503: --- Github user ijuma closed the pull request a

[jira] [Commented] (KAFKA-4492) java.lang.IllegalStateException: Attempting to put a clean entry for key... into NamedCache

[ https://issues.apache.org/jira/browse/KAFKA-4492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15729341#comment-15729341 ] ASF GitHub Bot commented on KAFKA-4492: --- GitHub user dguy opened a pull request:

[jira] [Commented] (KAFKA-4445) PreferredLeaderElectionCommand should query zk only once per topic

[ https://issues.apache.org/jira/browse/KAFKA-4445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15729435#comment-15729435 ] ASF GitHub Bot commented on KAFKA-4445: --- Github user asfgit closed the pull request

[jira] [Commented] (KAFKA-4492) java.lang.IllegalStateException: Attempting to put a clean entry for key... into NamedCache

[ https://issues.apache.org/jira/browse/KAFKA-4492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15729783#comment-15729783 ] ASF GitHub Bot commented on KAFKA-4492: --- Github user asfgit closed the pull request

[jira] [Commented] (KAFKA-4510) StreamThread must finish rebalance in state PENDING_SHUTDOWN

[ https://issues.apache.org/jira/browse/KAFKA-4510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15730369#comment-15730369 ] ASF GitHub Bot commented on KAFKA-4510: --- GitHub user mjsax opened a pull request:

[jira] [Commented] (KAFKA-4447) Controller resigned but it also acts as a controller for a long time

[ https://issues.apache.org/jira/browse/KAFKA-4447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15730981#comment-15730981 ] ASF GitHub Bot commented on KAFKA-4447: --- Github user xiguantiaozhan closed the pull

[jira] [Commented] (KAFKA-4447) Controller resigned but it also acts as a controller for a long time

[ https://issues.apache.org/jira/browse/KAFKA-4447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15731033#comment-15731033 ] ASF GitHub Bot commented on KAFKA-4447: --- GitHub user xiguantiaozhan reopened a pull

[jira] [Commented] (KAFKA-4392) Failed to lock the state directory due to an unexpected exception

[ https://issues.apache.org/jira/browse/KAFKA-4392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15732598#comment-15732598 ] ASF GitHub Bot commented on KAFKA-4392: --- Github user asfgit closed the pull request

[jira] [Commented] (KAFKA-4498) Extract Streams section as a separate page from documentation.html

[ https://issues.apache.org/jira/browse/KAFKA-4498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15733094#comment-15733094 ] ASF GitHub Bot commented on KAFKA-4498: --- Github user guozhangwang closed the pull re

[jira] [Commented] (KAFKA-3008) Connect should parallelize task start/stop

[ https://issues.apache.org/jira/browse/KAFKA-3008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15733704#comment-15733704 ] ASF GitHub Bot commented on KAFKA-3008: --- GitHub user shikhar opened a pull request:

[jira] [Commented] (KAFKA-4509) Task reusage on rebalance fails for threads on same host

[ https://issues.apache.org/jira/browse/KAFKA-4509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15733842#comment-15733842 ] ASF GitHub Bot commented on KAFKA-4509: --- GitHub user mjsax opened a pull request:

[jira] [Commented] (KAFKA-4431) HeartbeatThread should be a daemon thread

[ https://issues.apache.org/jira/browse/KAFKA-4431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15735393#comment-15735393 ] ASF GitHub Bot commented on KAFKA-4431: --- GitHub user rajinisivaram opened a pull req

[jira] [Commented] (KAFKA-4516) When a CachingStateStore is closed it should clear its associated NamedCache. Subsequent queries should throw InvalidStateStoreException

[ https://issues.apache.org/jira/browse/KAFKA-4516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15735855#comment-15735855 ] ASF GitHub Bot commented on KAFKA-4516: --- GitHub user dguy opened a pull request:

[jira] [Commented] (KAFKA-4375) Kafka consumer may swallow some interrupts meant for the calling thread

[ https://issues.apache.org/jira/browse/KAFKA-4375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15736108#comment-15736108 ] ASF GitHub Bot commented on KAFKA-4375: --- Github user asfgit closed the pull request

[jira] [Commented] (KAFKA-4272) Kafka Connect batch scripts are missing under `bin/windows/`

[ https://issues.apache.org/jira/browse/KAFKA-4272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15736123#comment-15736123 ] ASF GitHub Bot commented on KAFKA-4272: --- Github user asfgit closed the pull request

[jira] [Commented] (KAFKA-4517) Remove kafka-consumer-offset-checker.sh script since already deprecated in Kafka 9

[ https://issues.apache.org/jira/browse/KAFKA-4517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15736132#comment-15736132 ] ASF GitHub Bot commented on KAFKA-4517: --- GitHub user jeffwidman opened a pull reques

[jira] [Commented] (KAFKA-4000) Consumer per-topic metrics do not aggregate partitions from the same topic

[ https://issues.apache.org/jira/browse/KAFKA-4000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15736627#comment-15736627 ] ASF GitHub Bot commented on KAFKA-4000: --- Github user asfgit closed the pull request

[jira] [Commented] (KAFKA-4393) Improve invalid/negative TS handling

[ https://issues.apache.org/jira/browse/KAFKA-4393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15736779#comment-15736779 ] ASF GitHub Bot commented on KAFKA-4393: --- Github user asfgit closed the pull request

[jira] [Commented] (KAFKA-4486) Kafka Streams - exception in process still commits offsets

[ https://issues.apache.org/jira/browse/KAFKA-4486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15736912#comment-15736912 ] ASF GitHub Bot commented on KAFKA-4486: --- Github user asfgit closed the pull request

[jira] [Commented] (KAFKA-3008) Connect should parallelize task start/stop

[ https://issues.apache.org/jira/browse/KAFKA-3008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15738466#comment-15738466 ] ASF GitHub Bot commented on KAFKA-3008: --- Github user asfgit closed the pull request

[jira] [Commented] (KAFKA-4476) Kafka Streams gets stuck if metadata is missing

[ https://issues.apache.org/jira/browse/KAFKA-4476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15739141#comment-15739141 ] ASF GitHub Bot commented on KAFKA-4476: --- Github user asfgit closed the pull request

[jira] [Commented] (KAFKA-4510) StreamThread must finish rebalance in state PENDING_SHUTDOWN

[ https://issues.apache.org/jira/browse/KAFKA-4510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15739151#comment-15739151 ] ASF GitHub Bot commented on KAFKA-4510: --- Github user asfgit closed the pull request

[jira] [Commented] (KAFKA-4521) MirrorMaker should flush all messages before releasing partition ownership during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-4521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15739243#comment-15739243 ] ASF GitHub Bot commented on KAFKA-4521: --- GitHub user lindong28 opened a pull request

[jira] [Commented] (KAFKA-4497) log cleaner breaks on timeindex

[ https://issues.apache.org/jira/browse/KAFKA-4497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15740662#comment-15740662 ] ASF GitHub Bot commented on KAFKA-4497: --- GitHub user becketqin opened a pull request

[jira] [Commented] (KAFKA-4497) log cleaner breaks on timeindex

[ https://issues.apache.org/jira/browse/KAFKA-4497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15740688#comment-15740688 ] ASF GitHub Bot commented on KAFKA-4497: --- GitHub user becketqin opened a pull request

[jira] [Commented] (KAFKA-4140) Update system tests to allow running tests in parallel

[ https://issues.apache.org/jira/browse/KAFKA-4140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15740786#comment-15740786 ] ASF GitHub Bot commented on KAFKA-4140: --- Github user asfgit closed the pull request

[jira] [Commented] (KAFKA-4431) HeartbeatThread should be a daemon thread

[ https://issues.apache.org/jira/browse/KAFKA-4431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15740830#comment-15740830 ] ASF GitHub Bot commented on KAFKA-4431: --- Github user asfgit closed the pull request

[jira] [Commented] (KAFKA-4490) Add Global Table support to Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-4490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15741697#comment-15741697 ] ASF GitHub Bot commented on KAFKA-4490: --- GitHub user dguy opened a pull request:

[jira] [Commented] (KAFKA-4405) Kafka consumer improperly send prefetch request

[ https://issues.apache.org/jira/browse/KAFKA-4405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15742591#comment-15742591 ] ASF GitHub Bot commented on KAFKA-4405: --- Github user asfgit closed the pull request

[jira] [Commented] (KAFKA-4525) Kafka should not require SSL trust store password

[ https://issues.apache.org/jira/browse/KAFKA-4525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15743052#comment-15743052 ] ASF GitHub Bot commented on KAFKA-4525: --- GitHub user granthenke opened a pull reques

[jira] [Commented] (KAFKA-4516) When a CachingStateStore is closed it should clear its associated NamedCache. Subsequent queries should throw InvalidStateStoreException

[ https://issues.apache.org/jira/browse/KAFKA-4516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15743831#comment-15743831 ] ASF GitHub Bot commented on KAFKA-4516: --- Github user asfgit closed the pull request

[jira] [Commented] (KAFKA-4473) RecordCollector should handle retriable exceptions more strictly

[ https://issues.apache.org/jira/browse/KAFKA-4473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15744756#comment-15744756 ] ASF GitHub Bot commented on KAFKA-4473: --- GitHub user dguy opened a pull request:

[jira] [Commented] (KAFKA-4497) log cleaner breaks on timeindex

[ https://issues.apache.org/jira/browse/KAFKA-4497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15745742#comment-15745742 ] ASF GitHub Bot commented on KAFKA-4497: --- Github user asfgit closed the pull request

[jira] [Commented] (KAFKA-4532) StateStores can be connected to the wrong source topic resulting in incorrect metadata returned from IQ

[ https://issues.apache.org/jira/browse/KAFKA-4532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15745809#comment-15745809 ] ASF GitHub Bot commented on KAFKA-4532: --- GitHub user dguy opened a pull request:

[jira] [Commented] (KAFKA-4269) Multiple KStream instances with at least one Regex source causes NPE when using multiple consumers

[ https://issues.apache.org/jira/browse/KAFKA-4269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15745818#comment-15745818 ] ASF GitHub Bot commented on KAFKA-4269: --- Github user bbejeck closed the pull request

[jira] [Commented] (KAFKA-4390) Replace MessageSet usage with client-side equivalents

[ https://issues.apache.org/jira/browse/KAFKA-4390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15745892#comment-15745892 ] ASF GitHub Bot commented on KAFKA-4390: --- Github user asfgit closed the pull request

[jira] [Commented] (KAFKA-4529) tombstone may be removed earlier than it should

[ https://issues.apache.org/jira/browse/KAFKA-4529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15745956#comment-15745956 ] ASF GitHub Bot commented on KAFKA-4529: --- GitHub user becketqin opened a pull request

[jira] [Commented] (KAFKA-4509) Task reusage on rebalance fails for threads on same host

[ https://issues.apache.org/jira/browse/KAFKA-4509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15746138#comment-15746138 ] ASF GitHub Bot commented on KAFKA-4509: --- Github user asfgit closed the pull request

[jira] [Commented] (KAFKA-4532) StateStores can be connected to the wrong source topic resulting in incorrect metadata returned from IQ

[ https://issues.apache.org/jira/browse/KAFKA-4532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15746201#comment-15746201 ] ASF GitHub Bot commented on KAFKA-4532: --- Github user asfgit closed the pull request

[jira] [Commented] (KAFKA-4497) log cleaner breaks on timeindex

[ https://issues.apache.org/jira/browse/KAFKA-4497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15746249#comment-15746249 ] ASF GitHub Bot commented on KAFKA-4497: --- Github user becketqin closed the pull reque

[jira] [Commented] (KAFKA-3869) Fix streams example

[ https://issues.apache.org/jira/browse/KAFKA-3869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15746808#comment-15746808 ] ASF GitHub Bot commented on KAFKA-3869: --- Github user sakamotomsh closed the pull req

[jira] [Commented] (KAFKA-4030) Update older quickstart documents to clarify which version they relate to

[ https://issues.apache.org/jira/browse/KAFKA-4030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15746872#comment-15746872 ] ASF GitHub Bot commented on KAFKA-4030: --- Github user guozhangwang commented on the i

[jira] [Commented] (KAFKA-4534) StreamPartitionAssignor only ever updates the partitionsByHostState and metadataWithInternalTopics once.

[ https://issues.apache.org/jira/browse/KAFKA-4534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15747970#comment-15747970 ] ASF GitHub Bot commented on KAFKA-4534: --- GitHub user dguy opened a pull request:

[jira] [Commented] (KAFKA-4537) StreamPartitionAssignor incorrectly adds standby partitions to the partitionsByHostState map

[ https://issues.apache.org/jira/browse/KAFKA-4537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15748147#comment-15748147 ] ASF GitHub Bot commented on KAFKA-4537: --- GitHub user dguy opened a pull request:

[jira] [Commented] (KAFKA-4539) NPE in StreamThread when creating StandbyTasks

[ https://issues.apache.org/jira/browse/KAFKA-4539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15748306#comment-15748306 ] ASF GitHub Bot commented on KAFKA-4539: --- GitHub user dguy opened a pull request:

[jira] [Commented] (KAFKA-4534) StreamPartitionAssignor only ever updates the partitionsByHostState and metadataWithInternalTopics once.

[ https://issues.apache.org/jira/browse/KAFKA-4534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15748376#comment-15748376 ] ASF GitHub Bot commented on KAFKA-4534: --- Github user dguy closed the pull request at

[jira] [Commented] (KAFKA-4534) StreamPartitionAssignor only ever updates the partitionsByHostState and metadataWithInternalTopics once.

[ https://issues.apache.org/jira/browse/KAFKA-4534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15748380#comment-15748380 ] ASF GitHub Bot commented on KAFKA-4534: --- GitHub user dguy opened a pull request:

[jira] [Commented] (KAFKA-4529) tombstone may be removed earlier than it should

[ https://issues.apache.org/jira/browse/KAFKA-4529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15750478#comment-15750478 ] ASF GitHub Bot commented on KAFKA-4529: --- GitHub user becketqin opened a pull request

[jira] [Commented] (KAFKA-4529) tombstone may be removed earlier than it should

[ https://issues.apache.org/jira/browse/KAFKA-4529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15752230#comment-15752230 ] ASF GitHub Bot commented on KAFKA-4529: --- Github user asfgit closed the pull request

[jira] [Commented] (KAFKA-4521) MirrorMaker should flush all messages before releasing partition ownership during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-4521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15752550#comment-15752550 ] ASF GitHub Bot commented on KAFKA-4521: --- Github user asfgit closed the pull request

[jira] [Commented] (KAFKA-4548) Add CompatibilityTest to verify that individual features are supported or not by the broker we're connecting to

[ https://issues.apache.org/jira/browse/KAFKA-4548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15752717#comment-15752717 ] ASF GitHub Bot commented on KAFKA-4548: --- GitHub user cmccabe opened a pull request:

[jira] [Commented] (KAFKA-4508) Create system tests that run newer versions of the client against older versions of the broker

[ https://issues.apache.org/jira/browse/KAFKA-4508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15752827#comment-15752827 ] ASF GitHub Bot commented on KAFKA-4508: --- GitHub user cmccabe opened a pull request:

[jira] [Commented] (KAFKA-4451) Recovering empty replica yields negative offsets in index of compact partitions

[ https://issues.apache.org/jira/browse/KAFKA-4451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15752877#comment-15752877 ] ASF GitHub Bot commented on KAFKA-4451: --- Github user asfgit closed the pull request

[jira] [Commented] (KAFKA-4537) StreamPartitionAssignor incorrectly adds standby partitions to the partitionsByHostState map

[ https://issues.apache.org/jira/browse/KAFKA-4537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15753018#comment-15753018 ] ASF GitHub Bot commented on KAFKA-4537: --- Github user asfgit closed the pull request

[jira] [Commented] (KAFKA-4539) StreamThread is not correctly creating StandbyTasks

[ https://issues.apache.org/jira/browse/KAFKA-4539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15753082#comment-15753082 ] ASF GitHub Bot commented on KAFKA-4539: --- Github user asfgit closed the pull request

[jira] [Commented] (KAFKA-4507) The client should send older versions of requests to the broker if necessary

[ https://issues.apache.org/jira/browse/KAFKA-4507?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15753134#comment-15753134 ] ASF GitHub Bot commented on KAFKA-4507: --- GitHub user cmccabe opened a pull request:

[jira] [Commented] (KAFKA-4549) KafkaLZ4OutputStream output invalid format when it was called close method without flash method

[ https://issues.apache.org/jira/browse/KAFKA-4549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15753488#comment-15753488 ] ASF GitHub Bot commented on KAFKA-4549: --- GitHub user fossamagna opened a pull reques

[jira] [Commented] (KAFKA-4540) Suspended tasks that are not assigned to the StreamThread need to be closed before new active and standby tasks are created

[ https://issues.apache.org/jira/browse/KAFKA-4540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15753862#comment-15753862 ] ASF GitHub Bot commented on KAFKA-4540: --- GitHub user dguy opened a pull request:

[jira] [Commented] (KAFKA-4514) Add Codec for ZStandard Compression

[ https://issues.apache.org/jira/browse/KAFKA-4514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15753970#comment-15753970 ] ASF GitHub Bot commented on KAFKA-4514: --- GitHub user dongjinleekr opened a pull requ

[jira] [Commented] (KAFKA-4552) README.md has org.gradle.project.maxParallelForms instead of maxParallelForks

[ https://issues.apache.org/jira/browse/KAFKA-4552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15755665#comment-15755665 ] ASF GitHub Bot commented on KAFKA-4552: --- GitHub user cmccabe opened a pull request:

[jira] [Commented] (KAFKA-4552) README.md has org.gradle.project.maxParallelForms instead of maxParallelForks

[ https://issues.apache.org/jira/browse/KAFKA-4552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15755746#comment-15755746 ] ASF GitHub Bot commented on KAFKA-4552: --- Github user asfgit closed the pull request

[jira] [Commented] (KAFKA-3600) Enhance java clients to use ApiVersion Req/Resp to check if the broker they are talking to supports required api versions

[ https://issues.apache.org/jira/browse/KAFKA-3600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15756930#comment-15756930 ] ASF GitHub Bot commented on KAFKA-3600: --- Github user asfgit closed the pull request

[jira] [Commented] (KAFKA-4553) Connect's round robin assignment produces undesirable distribution of connectors/tasks

[ https://issues.apache.org/jira/browse/KAFKA-4553?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15757854#comment-15757854 ] ASF GitHub Bot commented on KAFKA-4553: --- GitHub user ewencp opened a pull request:

[jira] [Commented] (KAFKA-4555) Using Hamcrest for easy intent expression in tests

[ https://issues.apache.org/jira/browse/KAFKA-4555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15759489#comment-15759489 ] ASF GitHub Bot commented on KAFKA-4555: --- GitHub user rekhajoshm opened a pull reques

[jira] [Commented] (KAFKA-4534) StreamPartitionAssignor only ever updates the partitionsByHostState and metadataWithInternalTopics once.

[ https://issues.apache.org/jira/browse/KAFKA-4534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15762205#comment-15762205 ] ASF GitHub Bot commented on KAFKA-4534: --- Github user asfgit closed the pull request

[jira] [Commented] (KAFKA-4553) Connect's round robin assignment produces undesirable distribution of connectors/tasks

[ https://issues.apache.org/jira/browse/KAFKA-4553?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15762247#comment-15762247 ] ASF GitHub Bot commented on KAFKA-4553: --- Github user asfgit closed the pull request

[jira] [Commented] (KAFKA-4527) Transient failure of ConnectDistributedTest.test_pause_and_resume_sink where paused connector produces messages

[ https://issues.apache.org/jira/browse/KAFKA-4527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15762372#comment-15762372 ] ASF GitHub Bot commented on KAFKA-4527: --- GitHub user shikhar opened a pull request:

[jira] [Commented] (KAFKA-4526) Transient failure in ThrottlingTest.test_throttled_reassignment

[ https://issues.apache.org/jira/browse/KAFKA-4526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15762495#comment-15762495 ] ASF GitHub Bot commented on KAFKA-4526: --- GitHub user apurvam opened a pull request:

[jira] [Commented] (KAFKA-4166) TestMirrorMakerService.test_bounce transient system test failure

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

[jira] [Commented] (KAFKA-4166) TestMirrorMakerService.test_bounce transient system test failure

[ https://issues.apache.org/jira/browse/KAFKA-4166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15762654#comment-15762654 ] ASF GitHub Bot commented on KAFKA-4166: --- Github user asfgit closed the pull request

[jira] [Commented] (KAFKA-4526) Transient failure in ThrottlingTest.test_throttled_reassignment

[ https://issues.apache.org/jira/browse/KAFKA-4526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15762663#comment-15762663 ] ASF GitHub Bot commented on KAFKA-4526: --- Github user asfgit closed the pull request

[jira] [Commented] (KAFKA-4447) Controller resigned but it also acts as a controller for a long time

[ https://issues.apache.org/jira/browse/KAFKA-4447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15763005#comment-15763005 ] ASF GitHub Bot commented on KAFKA-4447: --- Github user asfgit closed the pull request

[jira] [Commented] (KAFKA-4554) ReplicaVerificationToolTest.test_replica_lags system test failure

[ https://issues.apache.org/jira/browse/KAFKA-4554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15764099#comment-15764099 ] ASF GitHub Bot commented on KAFKA-4554: --- GitHub user ijuma opened a pull request:

[jira] [Commented] (KAFKA-4500) Kafka Code Improvements

[ https://issues.apache.org/jira/browse/KAFKA-4500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15764121#comment-15764121 ] ASF GitHub Bot commented on KAFKA-4500: --- Github user asfgit closed the pull request

[jira] [Commented] (KAFKA-4473) RecordCollector should handle retriable exceptions more strictly

[ https://issues.apache.org/jira/browse/KAFKA-4473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15764822#comment-15764822 ] ASF GitHub Bot commented on KAFKA-4473: --- Github user asfgit closed the pull request

[jira] [Commented] (KAFKA-4540) Suspended tasks that are not assigned to the StreamThread need to be closed before new active and standby tasks are created

[ https://issues.apache.org/jira/browse/KAFKA-4540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15764886#comment-15764886 ] ASF GitHub Bot commented on KAFKA-4540: --- Github user asfgit closed the pull request

[jira] [Commented] (KAFKA-4561) Ordering of operations in StreamThread.shutdownTasksAndState may void at-least-once guarantees

[ https://issues.apache.org/jira/browse/KAFKA-4561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15764971#comment-15764971 ] ASF GitHub Bot commented on KAFKA-4561: --- GitHub user dguy opened a pull request:

[jira] [Commented] (KAFKA-4554) ReplicaBuffer.verifyChecksum should use use iterators instead of iterables

[ https://issues.apache.org/jira/browse/KAFKA-4554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15765006#comment-15765006 ] ASF GitHub Bot commented on KAFKA-4554: --- Github user asfgit closed the pull request

[jira] [Commented] (KAFKA-1833) OfflinePartitionLeaderSelector may return null leader when ISR and Assgined Broker have no common

[ https://issues.apache.org/jira/browse/KAFKA-1833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15765833#comment-15765833 ] ASF GitHub Bot commented on KAFKA-1833: --- Github user tedxia closed the pull request

[jira] [Commented] (KAFKA-269) ./system_test/producer_perf/bin/run-test.sh without --async flag does not run

[ https://issues.apache.org/jira/browse/KAFKA-269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15765906#comment-15765906 ] ASF GitHub Bot commented on KAFKA-269: -- Github user rekhajoshm closed the pull request

[jira] [Commented] (KAFKA-1972) JMX Tool output for CSV format does not handle attributes with comma in their value

[ https://issues.apache.org/jira/browse/KAFKA-1972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15765908#comment-15765908 ] ASF GitHub Bot commented on KAFKA-1972: --- Github user rekhajoshm closed the pull requ

[jira] [Commented] (KAFKA-4485) Follower should be in the isr if its FetchRequest has fetched up to the logEndOffset of leader

[ https://issues.apache.org/jira/browse/KAFKA-4485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15766182#comment-15766182 ] ASF GitHub Bot commented on KAFKA-4485: --- Github user asfgit closed the pull request

[jira] [Commented] (KAFKA-4426) Add consumer.close(timeout, unit) for graceful close with timeout

[ https://issues.apache.org/jira/browse/KAFKA-4426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15766945#comment-15766945 ] ASF GitHub Bot commented on KAFKA-4426: --- GitHub user rajinisivaram opened a pull req

[jira] [Commented] (KAFKA-2980) ZookeeperConsumerConnector may enter deadlock if a rebalance occurs during a stream creation.

[ https://issues.apache.org/jira/browse/KAFKA-2980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15768278#comment-15768278 ] ASF GitHub Bot commented on KAFKA-2980: --- Github user becketqin closed the pull reque

[jira] [Commented] (KAFKA-3284) Consider removing beta label in security documentation

[ https://issues.apache.org/jira/browse/KAFKA-3284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15768357#comment-15768357 ] ASF GitHub Bot commented on KAFKA-3284: --- GitHub user ijuma opened a pull request:

[jira] [Commented] (KAFKA-3355) GetOffsetShell command doesn't work with SASL enabled Kafka

[ https://issues.apache.org/jira/browse/KAFKA-3355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15769800#comment-15769800 ] ASF GitHub Bot commented on KAFKA-3355: --- GitHub user garmes-gdev opened a pull reque

[jira] [Commented] (KAFKA-3284) Consider removing beta label in security documentation

[ https://issues.apache.org/jira/browse/KAFKA-3284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15770414#comment-15770414 ] ASF GitHub Bot commented on KAFKA-3284: --- Github user asfgit closed the pull request

[jira] [Commented] (KAFKA-4259) Enable JAAS configuration for Kafka clients without a config file

[ https://issues.apache.org/jira/browse/KAFKA-4259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15774620#comment-15774620 ] ASF GitHub Bot commented on KAFKA-4259: --- Github user asfgit closed the pull request

[jira] [Commented] (KAFKA-4527) Transient failure of ConnectDistributedTest.test_pause_and_resume_sink where paused connector produces messages

[ https://issues.apache.org/jira/browse/KAFKA-4527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15775514#comment-15775514 ] ASF GitHub Bot commented on KAFKA-4527: --- Github user asfgit closed the pull request

[jira] [Commented] (KAFKA-4529) tombstone may be removed earlier than it should

[ https://issues.apache.org/jira/browse/KAFKA-4529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15777443#comment-15777443 ] ASF GitHub Bot commented on KAFKA-4529: --- Github user becketqin closed the pull reque

[jira] [Commented] (KAFKA-3564) Count metric always increments by 1.0

[ https://issues.apache.org/jira/browse/KAFKA-3564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15779103#comment-15779103 ] ASF GitHub Bot commented on KAFKA-3564: --- Github user pono closed the pull request at

[jira] [Commented] (KAFKA-3378) Client blocks forever if SocketChannel connects instantly

[ https://issues.apache.org/jira/browse/KAFKA-3378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15779105#comment-15779105 ] ASF GitHub Bot commented on KAFKA-3378: --- Github user pono closed the pull request at

[jira] [Commented] (KAFKA-2120) Add a request timeout to NetworkClient

[ https://issues.apache.org/jira/browse/KAFKA-2120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15779104#comment-15779104 ] ASF GitHub Bot commented on KAFKA-2120: --- Github user pono closed the pull request at

[jira] [Commented] (KAFKA-3054) Connect Herder fail forever if sent a wrong connector config or task config

[ https://issues.apache.org/jira/browse/KAFKA-3054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15779106#comment-15779106 ] ASF GitHub Bot commented on KAFKA-3054: --- Github user pono closed the pull request at

[jira] [Commented] (KAFKA-2698) add paused API

[ https://issues.apache.org/jira/browse/KAFKA-2698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15779110#comment-15779110 ] ASF GitHub Bot commented on KAFKA-2698: --- Github user pono closed the pull request at

[jira] [Commented] (KAFKA-1911) Log deletion on stopping replicas should be async

[ https://issues.apache.org/jira/browse/KAFKA-1911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15779108#comment-15779108 ] ASF GitHub Bot commented on KAFKA-1911: --- Github user pono closed the pull request at

[jira] [Commented] (KAFKA-2442) QuotasTest should not fail when cpu is busy

[ https://issues.apache.org/jira/browse/KAFKA-2442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15779109#comment-15779109 ] ASF GitHub Bot commented on KAFKA-2442: --- Github user pono closed the pull request at

[jira] [Commented] (KAFKA-1543) Changing replication factor

[ https://issues.apache.org/jira/browse/KAFKA-1543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15779114#comment-15779114 ] ASF GitHub Bot commented on KAFKA-1543: --- Github user pono closed the pull request at

[jira] [Commented] (KAFKA-2170) 10 LogTest cases failed for file.renameTo failed under windows

[ https://issues.apache.org/jira/browse/KAFKA-2170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15779115#comment-15779115 ] ASF GitHub Bot commented on KAFKA-2170: --- Github user pono closed the pull request at

<    3   4   5   6   7   8   9   10   11   12   >