[jira] [Commented] (KAFKA-4355) StreamThread intermittently dies with "Topic not found during partition assignment" when broker restarted

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

[jira] [Commented] (KAFKA-4273) Streams DSL - Add TTL / retention period support for intermediate topics and state stores

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

[jira] [Commented] (KAFKA-4095) When a topic is deleted and then created with the same name, 'committed' offsets are not reset

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

[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=15688328#comment-15688328 ] ASF GitHub Bot commented on KAFKA-4392: --- Github user guozhangwang closed the pull re

[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=15688329#comment-15688329 ] ASF GitHub Bot commented on KAFKA-4392: --- GitHub user guozhangwang reopened a pull re

[jira] [Commented] (KAFKA-4362) Consumer can fail after reassignment of the offsets topic partition

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

[jira] [Commented] (KAFKA-4307) Inconsistent parameters between console producer and consumer

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

[jira] [Commented] (KAFKA-4395) KafkaConfig and LogConfig should not have static initialization order dependencies

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

[jira] [Commented] (KAFKA-4438) BACKPORT - Add scala 2.12 support

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

[jira] [Commented] (KAFKA-1429) Yet another deadlock in controller shutdown

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

[jira] [Commented] (KAFKA-4331) Kafka Streams resetter is slow because it joins the same group for each topic

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

[jira] [Commented] (KAFKA-4424) Make serializer classes final

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

[jira] [Commented] (KAFKA-4345) Run decktape test for each pull request

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

[jira] [Commented] (KAFKA-4440) Make producer RecordMetadata non-final

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

[jira] [Commented] (KAFKA-4384) ReplicaFetcherThread stopped after ReplicaFetcherThread received a corrupted message

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

[jira] [Commented] (KAFKA-3452) Support session windows

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

[jira] [Commented] (KAFKA-4442) Controller should grab lock when it is being initialized to avoid race condition

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

[jira] [Commented] (KAFKA-4415) Reduce time to create and send MetadataUpdateRequest

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

[jira] [Commented] (KAFKA-4443) Controller should send UpdateMetadataRequest prior to LeaderAndIsrRequest during failover

[ https://issues.apache.org/jira/browse/KAFKA-4443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15694806#comment-15694806 ] ASF GitHub Bot commented on KAFKA-4443: --- GitHub user lindong28 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=15694953#comment-15694953 ] ASF GitHub Bot commented on KAFKA-4445: --- GitHub user lindong28 opened a pull request

[jira] [Commented] (KAFKA-4427) Skip topicGroups with no tasks

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

[jira] [Commented] (KAFKA-4245) BlockingChannel#connect hides all exceptions

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

[jira] [Commented] (KAFKA-4449) Add Serializer/Deserializer for POJO

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

[jira] [Commented] (KAFKA-4229) Controller can't start after several zk expired event

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

[jira] [Commented] (KAFKA-4403) Update KafkaBasedLog to use new endOffsets consumer API

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

[jira] [Commented] (KAFKA-3959) __consumer_offsets wrong number of replicas at startup

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

[jira] [Commented] (KAFKA-3637) Add method that checks if streams are initialised

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

[jira] [Commented] (KAFKA-4427) Skip topicGroups with no tasks

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

[jira] [Commented] (KAFKA-4427) Skip topicGroups with no tasks

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

[jira] [Commented] (KAFKA-3637) Add method that checks if streams are initialised

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

[jira] [Commented] (KAFKA-4439) Add a builder to NetworkClient

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

[jira] [Commented] (KAFKA-4453) add request prioritization

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

[jira] [Commented] (KAFKA-2122) Remove controller.message.queue.size Config

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

[jira] [Commented] (KAFKA-4457) Add a command to list the broker version information

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

[jira] [Commented] (KAFKA-4444) Aggregate requests sent from controller to broker during controlled shutdown

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

[jira] [Commented] (KAFKA-4458) Add per partition metrics for in-sync and assigned replica count

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

[jira] [Commented] (KAFKA-4345) Run decktape test for each pull request

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

[jira] [Commented] (KAFKA-4455) CommitFailedException during rebalance doesn't release resources in tasks/processors

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

[jira] [Commented] (KAFKA-3637) Add method that checks if streams are initialised

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

[jira] [Commented] (KAFKA-3637) Add method that checks if streams are initialised

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

[jira] [Commented] (KAFKA-4345) Run decktape test for each pull request

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

[jira] [Commented] (KAFKA-4245) BlockingChannel#connect hides all exceptions

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

[jira] [Commented] (KAFKA-4443) Controller should send UpdateMetadataRequest prior to LeaderAndIsrRequest during failover

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

[jira] [Commented] (KAFKA-3123) Follower Broker cannot start if offsets are already out of range

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

[jira] [Commented] (KAFKA-4415) Reduce time to create and send MetadataUpdateRequest

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

[jira] [Commented] (KAFKA-4271) The console consumer fails on Windows with new consumer is used

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

[jira] [Commented] (KAFKA-4397) Refactor Connect backing stores for thread-safety

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

[jira] [Commented] (KAFKA-4469) Consumer throughput regression caused by decrease in max.poll.records

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

[jira] [Commented] (KAFKA-4403) Update KafkaBasedLog to use new endOffsets consumer API

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

[jira] [Commented] (KAFKA-4387) KafkaConsumer will enter an infinite loop if the polling thread is interrupted, and either commitSync or committed is called

[ https://issues.apache.org/jira/browse/KAFKA-4387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15707489#comment-15707489 ] ASF GitHub Bot commented on KAFKA-4387: --- 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=15707623#comment-15707623 ] ASF GitHub Bot commented on KAFKA-4447: --- GitHub user xiguantiaozhan opened a pull re

[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=15708050#comment-15708050 ] ASF GitHub Bot commented on KAFKA-4405: --- GitHub user enothereska opened a pull reque

[jira] [Commented] (KAFKA-4443) Controller should send UpdateMetadataRequest prior to LeaderAndIsrRequest during failover

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

[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=15709379#comment-15709379 ] ASF GitHub Bot commented on KAFKA-1911: --- Github user asfgit closed the pull request

[jira] [Commented] (KAFKA-4271) The console consumer fails on Windows with new consumer is used

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

[jira] [Commented] (KAFKA-4469) Consumer throughput regression caused by inefficient list removal and copy

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

[jira] [Commented] (KAFKA-3994) Deadlock between consumer heartbeat expiration and offset commit.

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

[jira] [Commented] (KAFKA-3994) Deadlock between consumer heartbeat expiration and offset commit.

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

[jira] [Commented] (KAFKA-3910) Cyclic schema support in ConnectSchema and SchemaBuilder

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

[jira] [Commented] (KAFKA-4465) Create docker image and scripts for running tests locally

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

[jira] [Commented] (KAFKA-3637) Add method that checks if streams are initialised

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

[jira] [Commented] (KAFKA-4438) BACKPORT - Add scala 2.12 support

[ https://issues.apache.org/jira/browse/KAFKA-4438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15711065#comment-15711065 ] ASF GitHub Bot commented on KAFKA-4438: --- Github user leachbj closed the 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=15711450#comment-15711450 ] ASF GitHub Bot commented on KAFKA-4405: --- Github user enothereska closed the pull req

[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=15711475#comment-15711475 ] ASF GitHub Bot commented on KAFKA-4405: --- GitHub user enothereska reopened a pull req

[jira] [Commented] (KAFKA-4443) Controller should send UpdateMetadataRequest prior to LeaderAndIsrRequest during failover

[ https://issues.apache.org/jira/browse/KAFKA-4443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15712288#comment-15712288 ] ASF GitHub Bot commented on KAFKA-4443: --- 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=15713303#comment-15713303 ] ASF GitHub Bot commented on KAFKA-3008: --- Github user asfgit closed the pull request

[jira] [Commented] (KAFKA-4161) Decouple flush and offset commits

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

[jira] [Commented] (KAFKA-4472) offsetRetentionMs miscalculated in GroupCoordinator

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

[jira] [Commented] (KAFKA-4306) Connect workers won't shut down if brokers are not available

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

[jira] [Commented] (KAFKA-4399) Deadlock between cleanupGroupMetadata and offset commit

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

[jira] [Commented] (KAFKA-2857) ConsumerGroupCommand throws GroupCoordinatorNotAvailableException when describing a non-existent group before the offset topic is created

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

[jira] [Commented] (KAFKA-2857) ConsumerGroupCommand throws GroupCoordinatorNotAvailableException when describing a non-existent group before the offset topic is created

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

[jira] [Commented] (KAFKA-2247) Merge kafka.utils.Time and kafka.common.utils.Time

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

[jira] [Commented] (KAFKA-4205) NullPointerException in fetchOffsetsBefore

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

[jira] [Commented] (KAFKA-4481) Relax Kafka Streams API type constraints

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

[jira] [Commented] (KAFKA-4454) Authorizer should also include the Principal generated by the PrincipalBuilder.

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

[jira] [Commented] (KAFKA-4483) Exception when creating topics

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

[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=15717277#comment-15717277 ] ASF GitHub Bot commented on KAFKA-4485: --- GitHub user lindong28 opened a pull request

[jira] [Commented] (KAFKA-4483) NPE in `Log` constructor if log level is INFO or finer

[ https://issues.apache.org/jira/browse/KAFKA-4483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15717341#comment-15717341 ] ASF GitHub Bot commented on KAFKA-4483: --- 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=15717780#comment-15717780 ] ASF GitHub Bot commented on KAFKA-4476: --- GitHub user mjsax opened a pull request:

[jira] [Commented] (KAFKA-4205) NullPointerException in fetchOffsetsBefore

[ https://issues.apache.org/jira/browse/KAFKA-4205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15720401#comment-15720401 ] ASF GitHub Bot commented on KAFKA-4205: --- Github user asfgit closed the 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=15720715#comment-15720715 ] ASF GitHub Bot commented on KAFKA-4451: --- GitHub user michaelschiff opened a pull req

[jira] [Commented] (KAFKA-4488) UnsupportedOperationException during initialization of StandbyTask

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

[jira] [Commented] (KAFKA-3994) Deadlock between consumer heartbeat expiration and offset commit.

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

[jira] [Commented] (KAFKA-3038) Speeding up partition reassignment after broker failure

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

[jira] [Commented] (KAFKA-1595) Remove deprecated and slower scala JSON parser from kafka.consumer.TopicCount

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

[jira] [Commented] (KAFKA-4472) offsetRetentionMs miscalculated in GroupCoordinator

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

[jira] [Commented] (KAFKA-3537) Provide access to low-level Metrics in ProcessorContext

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

[jira] [Commented] (KAFKA-4488) UnsupportedOperationException during initialization of StandbyTask

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

[jira] [Commented] (KAFKA-4480) kafka-configs will execute the removal of an invalid property and not report an error

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

[jira] [Commented] (KAFKA-4306) Connect workers won't shut down if brokers are not available

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

[jira] [Commented] (KAFKA-4442) Controller should grab lock when it is being initialized to avoid race condition

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

[jira] [Commented] (KAFKA-4458) Add per partition metrics for in-sync and assigned replica count

[ https://issues.apache.org/jira/browse/KAFKA-4458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15727206#comment-15727206 ] ASF GitHub Bot commented on KAFKA-4458: --- 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=15727259#comment-15727259 ] ASF GitHub Bot commented on KAFKA-4498: --- GitHub user guozhangwang opened a pull requ

[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=15727288#comment-15727288 ] ASF GitHub Bot commented on KAFKA-4498: --- Github user guozhangwang commented on the i

[jira] [Commented] (KAFKA-4500) Code Corrections

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

[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=15728735#comment-15728735 ] ASF GitHub Bot commented on KAFKA-4503: --- GitHub user ijuma opened a 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=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:

<    7   8   9   10   11   12   13   14   >