Pavol Ipoth created KAFKA-10160:
---
Summary: Kafka MM2 consumer configuration
Key: KAFKA-10160
URL: https://issues.apache.org/jira/browse/KAFKA-10160
Project: Kafka
Issue Type: Bug
Affects Ve
David Jacot created KAFKA-10161:
---
Summary: Update Documentation
Key: KAFKA-10161
URL: https://issues.apache.org/jira/browse/KAFKA-10161
Project: Kafka
Issue Type: Sub-task
Reporter:
David Jacot created KAFKA-10162:
---
Summary: Update Rate implementation to cope with spiky workload
Key: KAFKA-10162
URL: https://issues.apache.org/jira/browse/KAFKA-10162
Project: Kafka
Issue Ty
David Jacot created KAFKA-10163:
---
Summary: Implement Broker side changes
Key: KAFKA-10163
URL: https://issues.apache.org/jira/browse/KAFKA-10163
Project: Kafka
Issue Type: Sub-task
David Jacot created KAFKA-10164:
---
Summary: Implement Admin side changes
Key: KAFKA-10164
URL: https://issues.apache.org/jira/browse/KAFKA-10164
Project: Kafka
Issue Type: Sub-task
R
jiameixie commented on pull request #8836:
URL: https://github.com/apache/kafka/pull/8836#issuecomment-643961078
> In the new code we may not trigger `onPartitionsRevoked` anymore although
`onPartitionsAssigned` is always triggered, so we can no longer rely on them to
measure the latency.
chia7712 commented on pull request #8853:
URL: https://github.com/apache/kafka/pull/8853#issuecomment-644004973
```StoreUpgradeIntegrationTest#shouldMigratePersistentKeyValueStoreToTimestampedKeyValueStoreUsingPapi```
is traced by https://issues.apache.org/jira/browse/KAFKA-10151
---
chia7712 edited a comment on pull request #8853:
URL: https://github.com/apache/kafka/pull/8853#issuecomment-644004973
```StoreUpgradeIntegrationTest#shouldMigratePersistentKeyValueStoreToTimestampedKeyValueStoreUsingPapi```
is traced by https://issues.apache.org/jira/browse/KAFKA-10151
chia7712 commented on pull request #8853:
URL: https://github.com/apache/kafka/pull/8853#issuecomment-644005216
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please lo
[
https://issues.apache.org/jira/browse/KAFKA-8835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Viktor Somogyi-Vass updated KAFKA-8835:
---
Issue Type: Task (was: Improvement)
> Update documentation for URP changes in KIP-35
[
https://issues.apache.org/jira/browse/KAFKA-8835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Viktor Somogyi-Vass updated KAFKA-8835:
---
Priority: Trivial (was: Major)
> Update documentation for URP changes in KIP-352
> -
showuon commented on pull request #8646:
URL: https://github.com/apache/kafka/pull/8646#issuecomment-644030596
Thanks for the suggestion, @guozhangwang , I removed the listeners. I agree
we can fix it in this way first, and keep monitoring it. Thanks.
-
chia7712 commented on a change in pull request #8836:
URL: https://github.com/apache/kafka/pull/8836#discussion_r440078358
##
File path: core/src/main/scala/kafka/tools/ConsumerPerformance.scala
##
@@ -45,40 +45,47 @@ object ConsumerPerformance extends LazyLogging {
val to
cadonna opened a new pull request #8872:
URL: https://github.com/apache/kafka/pull/8872
Without this fix the log message is
```
task [0_2] Transitioning state manager for ACTIVE task 0_2 to ACTIVE
```
but it should probably be
```
task [0_2] Transitioning state ma
cadonna commented on a change in pull request #8872:
URL: https://github.com/apache/kafka/pull/8872#discussion_r440139800
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java
##
@@ -509,11 +509,12 @@ void transitionTaskTyp
[
https://issues.apache.org/jira/browse/KAFKA-10160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17135815#comment-17135815
]
Ryanne Dolan commented on KAFKA-10160:
--
Agree this is a bug. This property is hard-
cadonna commented on pull request #8872:
URL: https://github.com/apache/kafka/pull/8872#issuecomment-644104290
Call for review: @ableegoldman @guozhangwang
This is an automated message from the Apache Git Service.
To respond
cadonna commented on a change in pull request #8872:
URL: https://github.com/apache/kafka/pull/8872#discussion_r440139800
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java
##
@@ -509,11 +509,12 @@ void transitionTaskTyp
[
https://issues.apache.org/jira/browse/KAFKA-10159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17135817#comment-17135817
]
Ryanne Dolan commented on KAFKA-10159:
--
I think you are missing target.cluster.boot
cadonna opened a new pull request #8873:
URL: https://github.com/apache/kafka/pull/8873
When a re-initialisation from checkpoint is skipped the following log
messages appear in the logs.
```
DEBUG stream-thread
[EosTest-a2c3b21b-7af1-4dce-a3e0-6dc10932e5a2-StreamThread-1] task [
cadonna commented on pull request #8873:
URL: https://github.com/apache/kafka/pull/8873#issuecomment-644109233
Call for review: @ableegoldman @guozhangwang @mjsax
This is an automated message from the Apache Git Service.
To
dajac commented on a change in pull request #8768:
URL: https://github.com/apache/kafka/pull/8768#discussion_r440028429
##
File path: clients/src/main/java/org/apache/kafka/common/metrics/Metrics.java
##
@@ -572,16 +572,18 @@ public synchronized void removeReporter(MetricsRepor
abbccdda commented on pull request #8831:
URL: https://github.com/apache/kafka/pull/8831#issuecomment-644109922
@jiameixie Let's continue the discussion on mailing thread to get KIP-487
approved first.
This is an automated m
showuon edited a comment on pull request #8646:
URL: https://github.com/apache/kafka/pull/8646#issuecomment-644030596
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
bbejeck commented on pull request #6229:
URL: https://github.com/apache/kafka/pull/6229#issuecomment-644170697
System test failed with `Failed while trying to discover tests: Didn't find
any tests for symbol
tests/kafkatest/tests/streams/streams_broker_down_resilience_test.py`.
@sh-
tombentley commented on pull request #8839:
URL: https://github.com/apache/kafka/pull/8839#issuecomment-644176096
@kkonstantine @rhauch any chance this could be merged for 2.6, or is it too
late now?
This is an automated mes
dajac commented on pull request #8808:
URL: https://github.com/apache/kafka/pull/8808#issuecomment-644192842
@tombentley I am not sure to follow what the `AppInfoParser` is doing
here... Could you elaborate a bit more?
Regarding option 2), I had a quick look at the implementation and
[
https://issues.apache.org/jira/browse/KAFKA-10109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tom Bentley updated KAFKA-10109:
Description:
{{AclCommand.AclCommandService}} uses {{withAdminClient(opts:
AclCommandOptions)(f:
vvcephei commented on pull request #8865:
URL: https://github.com/apache/kafka/pull/8865#issuecomment-644211672
Looks like a compile warning:
```
00:07:57.788 > Task :streams:compileJava
00:07:57.788
/home/jenkins/jenkins-slave/workspace/kafka-pr-jdk11-scala2.13/streams/src/mai
tombentley commented on pull request #8808:
URL: https://github.com/apache/kafka/pull/8808#issuecomment-644211634
@dajac the problem happens when `--command-config` is given on the command
line, and the config file defines a `client.id`. The `AppInfoParser` tries to
register an MBean whose
ableegoldman commented on a change in pull request #8872:
URL: https://github.com/apache/kafka/pull/8872#discussion_r440299033
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java
##
@@ -509,11 +509,12 @@ void transitionTa
guozhangwang commented on pull request #8646:
URL: https://github.com/apache/kafka/pull/8646#issuecomment-644247677
test this
This is an automated message from the Apache Git Service.
To respond to the message, please log on
[
https://issues.apache.org/jira/browse/KAFKA-10105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17136012#comment-17136012
]
Sophie Blee-Goldman commented on KAFKA-10105:
-
Did you upgrade the clients a
[
https://issues.apache.org/jira/browse/KAFKA-9989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9989:
---
Summary: Wait for stable assignment
StreamsUpgradeTest.test_metadata_upgrade (was:
StreamsUpgradeT
[
https://issues.apache.org/jira/browse/KAFKA-9989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9989:
---
Description:
After some discussion we believe there is room to improve the accuracy of this
test, by
[
https://issues.apache.org/jira/browse/KAFKA-8362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe updated KAFKA-8362:
Component/s: jbod
> LogCleaner gets stuck after partition move between log directories
> --
Sophie Blee-Goldman created KAFKA-10165:
---
Summary: Percentiles metric leaking memory
Key: KAFKA-10165
URL: https://issues.apache.org/jira/browse/KAFKA-10165
Project: Kafka
Issue Type: B
dongjinleekr commented on pull request #8117:
URL: https://github.com/apache/kafka/pull/8117#issuecomment-644277987
@vvcephei Here is the fix. The implementation you saw was the draft before
the discussion - Now it is updated, with rebasing onto the latest trunk. Don't
hesitate to talk to
[
https://issues.apache.org/jira/browse/KAFKA-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17136069#comment-17136069
]
Guozhang Wang commented on KAFKA-10134:
---
This is a bit weird to me -- discover of
guozhangwang commented on pull request #8873:
URL: https://github.com/apache/kafka/pull/8873#issuecomment-644280199
Cherry-picked to 2.6
This is an automated message from the Apache Git Service.
To respond to the message, ple
guozhangwang merged pull request #8873:
URL: https://github.com/apache/kafka/pull/8873
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go
guozhangwang commented on a change in pull request #8872:
URL: https://github.com/apache/kafka/pull/8872#discussion_r440348339
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java
##
@@ -509,11 +509,12 @@ void transitionTa
guozhangwang commented on pull request #8872:
URL: https://github.com/apache/kafka/pull/8872#issuecomment-644281735
Cherry-picked to 2.6.
This is an automated message from the Apache Git Service.
To respond to the message, pl
guozhangwang merged pull request #8872:
URL: https://github.com/apache/kafka/pull/8872
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go
[
https://issues.apache.org/jira/browse/KAFKA-10104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17136078#comment-17136078
]
Matthias J. Sax commented on KAFKA-10104:
-
It's for 3.0 (or maybe even 4.0), as
[
https://issues.apache.org/jira/browse/KAFKA-9681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17136084#comment-17136084
]
sats commented on KAFKA-9681:
-
This Requires a KIP.
> Change whitelist/blacklist terms
> --
chia7712 commented on pull request #8874:
URL: https://github.com/apache/kafka/pull/8874#issuecomment-644293179
@cadonna @guozhangwang Could you take a look?
This is an automated message from the Apache Git Service.
To respon
Sophie Blee-Goldman created KAFKA-10166:
---
Summary: Excessive TaskCorruptedException seen in soak
Key: KAFKA-10166
URL: https://issues.apache.org/jira/browse/KAFKA-10166
Project: Kafka
I
mjsax commented on pull request #8855:
URL: https://github.com/apache/kafka/pull/8855#issuecomment-644312790
Retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please log o
[
https://issues.apache.org/jira/browse/KAFKA-10166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman updated KAFKA-10166:
Summary: Excessive TaskCorruptedException seen in test applications (was:
Excessi
[
https://issues.apache.org/jira/browse/KAFKA-10166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman updated KAFKA-10166:
Summary: Excessive TaskCorruptedException seen in testing (was: Excessive
TaskCor
[
https://issues.apache.org/jira/browse/KAFKA-10166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman reassigned KAFKA-10166:
---
Assignee: Sophie Blee-Goldman
> Excessive TaskCorruptedException seen in te
[
https://issues.apache.org/jira/browse/KAFKA-10166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman updated KAFKA-10166:
Description: As the title indicates. Seen occasionally with ALOS (~20 times
in two
[
https://issues.apache.org/jira/browse/KAFKA-10166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman reassigned KAFKA-10166:
---
Assignee: (was: Sophie Blee-Goldman)
> Excessive TaskCorruptedException
[
https://issues.apache.org/jira/browse/KAFKA-10166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman updated KAFKA-10166:
Description:
As the title indicates, long-running test applications with injected
mjsax commented on pull request #8874:
URL: https://github.com/apache/kafka/pull/8874#issuecomment-644328634
Thanks! Was just about to do a hotfix PR myself.
This is an automated message from the Apache Git Service.
To respon
thomasrockhu opened a new pull request #8875:
URL: https://github.com/apache/kafka/pull/8875
*More detailed description of your change,
if necessary. The PR title and PR message become
the squashed commit message, so use a separate
comment to ping reviewers.*
*Summary of test
guozhangwang merged pull request #8874:
URL: https://github.com/apache/kafka/pull/8874
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go
guozhangwang commented on pull request #8874:
URL: https://github.com/apache/kafka/pull/8874#issuecomment-644329167
Ran checkstyle and spotbug locally and looks good.
This is an automated message from the Apache Git Service.
guozhangwang commented on pull request #8874:
URL: https://github.com/apache/kafka/pull/8874#issuecomment-644329675
To 2.6 as well.
This is an automated message from the Apache Git Service.
To respond to the message, please l
thomasrockhu closed pull request #8875:
URL: https://github.com/apache/kafka/pull/8875
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go
rhauch commented on pull request #8839:
URL: https://github.com/apache/kafka/pull/8839#issuecomment-644382512
@tombentley, yes we'll want to merge this and backport to the `2.6` branch.
That branch is not yet frozen for documentation or tests.
-
ableegoldman closed pull request #8868:
URL: https://github.com/apache/kafka/pull/8868
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go
benhannel commented on pull request #4204:
URL: https://github.com/apache/kafka/pull/4204#issuecomment-644416082
Perfect is the enemy of good. This issue has been unresolved for years
because of idealism.
This is an automate
benhannel edited a comment on pull request #4204:
URL: https://github.com/apache/kafka/pull/4204#issuecomment-644416082
Perfect is the enemy of good.
This is an automated message from the Apache Git Service.
To respond to the
michael-carter-instaclustr commented on pull request #8844:
URL: https://github.com/apache/kafka/pull/8844#issuecomment-63698
Failing unit test
kafka.admin.ReassignPartitionsUnitTest.testModifyBrokerThrottles is unrelated
to this pull request and is tracked by:
https://issues.apache.o
[
https://issues.apache.org/jira/browse/KAFKA-10062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17136199#comment-17136199
]
William Bottrell commented on KAFKA-10062:
--
Hi, [~psmolinski]. I'm looking into
ableegoldman commented on a change in pull request #8856:
URL: https://github.com/apache/kafka/pull/8856#discussion_r440473726
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java
##
@@ -539,19 +537,18 @@ private void writeCheckpoint
junrao commented on a change in pull request #8657:
URL: https://github.com/apache/kafka/pull/8657#discussion_r440514740
##
File path:
core/src/test/scala/unit/kafka/coordinator/group/GroupCoordinatorConcurrencyTest.scala
##
@@ -307,8 +307,14 @@ class GroupCoordinatorConcurren
junrao commented on a change in pull request #8657:
URL: https://github.com/apache/kafka/pull/8657#discussion_r440514740
##
File path:
core/src/test/scala/unit/kafka/coordinator/group/GroupCoordinatorConcurrencyTest.scala
##
@@ -307,8 +307,14 @@ class GroupCoordinatorConcurren
Guozhang Wang created KAFKA-10167:
-
Summary: Streams EOS-Beta should not try to get end-offsets as
read-committed
Key: KAFKA-10167
URL: https://issues.apache.org/jira/browse/KAFKA-10167
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-10167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17136215#comment-17136215
]
Guozhang Wang commented on KAFKA-10167:
---
The proposed solution is that even under
[
https://issues.apache.org/jira/browse/KAFKA-10167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17136216#comment-17136216
]
Guozhang Wang commented on KAFKA-10167:
---
I've also thought about whether we need t
guozhangwang opened a new pull request #8876:
URL: https://github.com/apache/kafka/pull/8876
Since admin client allows use to use flexible offset-spec, we can always set
to use read-uncommitted regardless of the eos config.
### Committer Checklist (excluded from commit message)
-
[
https://issues.apache.org/jira/browse/KAFKA-10167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-10167:
Affects Version/s: 2.6.0
> Streams EOS-Beta should not try to get end-offsets as read-comm
[
https://issues.apache.org/jira/browse/KAFKA-10167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-10167:
Fix Version/s: 2.6.0
> Streams EOS-Beta should not try to get end-offsets as read-committe
[
https://issues.apache.org/jira/browse/KAFKA-10167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-10167:
Priority: Blocker (was: Major)
> Streams EOS-Beta should not try to get end-offsets as re
[
https://issues.apache.org/jira/browse/KAFKA-10167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-10167:
Component/s: streams
> Streams EOS-Beta should not try to get end-offsets as read-committe
junrao commented on pull request #8479:
URL: https://github.com/apache/kafka/pull/8479#issuecomment-644476784
@andrewchoi5 : Since the controller only checks KAFKA_STORAGE_ERROR in
LeaderAndIsrResponse now, perhaps we can just log an error without sending an
error code back for now.
mjsax commented on a change in pull request #8876:
URL: https://github.com/apache/kafka/pull/8876#discussion_r440535836
##
File path:
clients/src/test/java/org/apache/kafka/clients/admin/MockAdminClient.java
##
@@ -834,6 +855,13 @@ public AlterClientQuotasResult
alterClientQu
[
https://issues.apache.org/jira/browse/KAFKA-10167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-10167:
---
Assignee: Guozhang Wang
> Streams EOS-Beta should not try to get end-offsets as rea
andrewchoi5 commented on pull request #8479:
URL: https://github.com/apache/kafka/pull/8479#issuecomment-644482079
Thanks, @junrao .
Removed the population of responseMap with the `ERROR` code.
This is an automated message
junrao commented on a change in pull request #7929:
URL: https://github.com/apache/kafka/pull/7929#discussion_r440539291
##
File path: core/src/main/scala/kafka/log/LogCleaner.scala
##
@@ -595,8 +595,10 @@ private[log] class Cleaner(val id: Int,
log.replaceSegments(List(
[
https://issues.apache.org/jira/browse/KAFKA-10062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17136232#comment-17136232
]
Matthias J. Sax commented on KAFKA-10062:
-
The testing is done using `TopologyTe
mjsax commented on pull request #8871:
URL: https://github.com/apache/kafka/pull/8871#issuecomment-644483903
Retest this please.
This is an automated message from the Apache Git Service.
To respond to the message, please log
mjsax commented on pull request #8861:
URL: https://github.com/apache/kafka/pull/8861#issuecomment-644484131
Retest this please.
This is an automated message from the Apache Git Service.
To respond to the message, please log
mjsax commented on pull request #8865:
URL: https://github.com/apache/kafka/pull/8865#issuecomment-644485931
Not sure if changing KIP-295 would be a good call. We made a mistake and can
be honest about it. I'll do a quick KIP.
--
Matthias J. Sax created KAFKA-10168:
---
Summary: Rename public StreamsConfig variable
Key: KAFKA-10168
URL: https://issues.apache.org/jira/browse/KAFKA-10168
Project: Kafka
Issue Type: Improv
[
https://issues.apache.org/jira/browse/KAFKA-10168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-10168:
---
Assignee: Matthias J. Sax
> Rename public StreamsConfig variable
>
[
https://issues.apache.org/jira/browse/KAFKA-10168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-10168:
Description:
All Kafka Streams configuration parameter are exposed via public variables th
[
https://issues.apache.org/jira/browse/KAFKA-10168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-10168:
Description:
All Kafka Streams configuration parameter are exposed via public variables th
Sophie Blee-Goldman created KAFKA-10169:
---
Summary: KafkaException: Failing batch since transaction was
aborted
Key: KAFKA-10169
URL: https://issues.apache.org/jira/browse/KAFKA-10169
Project: Ka
mjsax commented on a change in pull request #8856:
URL: https://github.com/apache/kafka/pull/8856#discussion_r440554249
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
##
@@ -714,13 +696,20 @@ void shutdown(final boolean clean)
mjsax commented on a change in pull request #8856:
URL: https://github.com/apache/kafka/pull/8856#discussion_r440555142
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
##
@@ -215,91 +215,54 @@ public void handleAssignment(final
mjsax commented on pull request #8856:
URL: https://github.com/apache/kafka/pull/8856#issuecomment-644498795
Retest this please.
This is an automated message from the Apache Git Service.
To respond to the message, please log
ableegoldman commented on a change in pull request #8856:
URL: https://github.com/apache/kafka/pull/8856#discussion_r440555458
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
##
@@ -215,91 +215,54 @@ public void handleAssignmen
mjsax commented on a change in pull request #8856:
URL: https://github.com/apache/kafka/pull/8856#discussion_r440555142
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
##
@@ -215,91 +215,54 @@ public void handleAssignment(final
satishbellapu opened a new pull request #8877:
URL: https://github.com/apache/kafka/pull/8877
Looks it is a typo, the actual key supposed to be this
#replicaFetchWaitMaxTimeMs(replica.fetch.wait.max.ms) instead of that the docs
have this #replicaMaxWaitTimeMs
### Committer Checklist
ableegoldman commented on a change in pull request #8856:
URL: https://github.com/apache/kafka/pull/8856#discussion_r440555918
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
##
@@ -714,13 +696,20 @@ void shutdown(final boolean
1 - 100 of 119 matches
Mail list logo
