jiamei xie created KAFKA-10126:
--
Summary: Remove unused options in ConsumerPerformance
Key: KAFKA-10126
URL: https://issues.apache.org/jira/browse/KAFKA-10126
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-7888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17129031#comment-17129031
]
Youssef BOUZAIENNE commented on KAFKA-7888:
---
I'm facing the same issue on 2.4.1
[
https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Karthik updated KAFKA-7500:
---
Comment: was deleted
(was: Hi All, Im unable to find a document for MM2, Any leads to the
documentation woul
[
https://issues.apache.org/jira/browse/KAFKA-10126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17129042#comment-17129042
]
Chia-Ping Tsai commented on KAFKA-10126:
How about making numThreadsOpt work? ma
Youssef BOUZAIENNE created KAFKA-10127:
--
Summary: kafka cluster not recovering - Shrinking ISR continously
Key: KAFKA-10127
URL: https://issues.apache.org/jira/browse/KAFKA-10127
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-10126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17129056#comment-17129056
]
jiamei xie commented on KAFKA-10126:
Ok. Thanks. I'll have a look at it. Use consume
[
https://issues.apache.org/jira/browse/KAFKA-10126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17129067#comment-17129067
]
Chia-Ping Tsai commented on KAFKA-10126:
> Use consumer group?
yep. Should we e
[
https://issues.apache.org/jira/browse/KAFKA-10105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17129070#comment-17129070
]
William Reynolds commented on KAFKA-10105:
--
Hi James, that looks really similar
[
https://issues.apache.org/jira/browse/KAFKA-9935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17129072#comment-17129072
]
William Reynolds commented on KAFKA-9935:
-
It does look related to me. Your repro
[
https://issues.apache.org/jira/browse/KAFKA-10107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17129077#comment-17129077
]
William Reynolds commented on KAFKA-10107:
--
Still working on getting the logs o
[
https://issues.apache.org/jira/browse/KAFKA-10126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17129079#comment-17129079
]
jiamei xie commented on KAFKA-10126:
Thanks. Got it. What's about numFetchersOpt? C
[
https://issues.apache.org/jira/browse/KAFKA-10126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17129108#comment-17129108
]
jiamei xie commented on KAFKA-10126:
> maybe add new argument to create topic with s
[
https://issues.apache.org/jira/browse/KAFKA-10126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17129108#comment-17129108
]
jiamei xie edited comment on KAFKA-10126 at 6/9/20, 10:11 AM:
[
https://issues.apache.org/jira/browse/KAFKA-10126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17129108#comment-17129108
]
jiamei xie edited comment on KAFKA-10126 at 6/9/20, 10:12 AM:
Karthik created KAFKA-10128:
---
Summary: MM2 - Delete topics when config sync is enabled
Key: KAFKA-10128
URL: https://issues.apache.org/jira/browse/KAFKA-10128
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-10128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17129139#comment-17129139
]
Karthik commented on KAFKA-10128:
-
It also the other way around where even deleted mirro
[
https://issues.apache.org/jira/browse/KAFKA-10128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17129139#comment-17129139
]
Karthik edited comment on KAFKA-10128 at 6/9/20, 11:34 AM:
---
It
[
https://issues.apache.org/jira/browse/KAFKA-10128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Karthik updated KAFKA-10128:
Reviewer: Ryanne Dolan
> MM2 - Delete topics when config sync is enabled
> ---
[
https://issues.apache.org/jira/browse/KAFKA-9800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Cheng Tan updated KAFKA-9800:
-
Description:
Design:
The main idea is to bookkeep the failed attempts. Making those class containing
re
[
https://issues.apache.org/jira/browse/KAFKA-9800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Cheng Tan updated KAFKA-9800:
-
Description:
Design:
The main idea is to bookkeep the failed attempt. Currently, the retry backoff
has
[
https://issues.apache.org/jira/browse/KAFKA-9800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Cheng Tan updated KAFKA-9800:
-
Description:
Design:
The main idea is to bookkeep the failed attempt. Currently, the retry backoff
has
[
https://issues.apache.org/jira/browse/KAFKA-9800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Cheng Tan updated KAFKA-9800:
-
Description:
Design:
The main idea is to bookkeep the failed attempt. Currently, the retry backoff
has
[
https://issues.apache.org/jira/browse/KAFKA-9724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Arthur resolved KAFKA-9724.
-
Fix Version/s: 2.6.0
Assignee: David Arthur
Resolution: Fixed
> Consumer wrongly
[
https://issues.apache.org/jira/browse/KAFKA-9724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Arthur updated KAFKA-9724:
Fix Version/s: 2.5.1
> Consumer wrongly ignores fetched records "since it no longer has valid
> po
[
https://issues.apache.org/jira/browse/KAFKA-9800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Cheng Tan updated KAFKA-9800:
-
Description:
Design:
The main idea is to bookkeep the failed attempt. Currently, the retry backoff
has
[
https://issues.apache.org/jira/browse/KAFKA-10127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Youssef BOUZAIENNE updated KAFKA-10127:
---
Description:
We are actually facing issue from time to time where our kafka cluster
[
https://issues.apache.org/jira/browse/KAFKA-9747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17129374#comment-17129374
]
Rodrigo commented on KAFKA-9747:
I have the same issue here... MongoDB (Atlas), MongoDB C
Chia-Ping Tsai created KAFKA-10129:
--
Summary: Fail the QA if there is javadoc error
Key: KAFKA-10129
URL: https://issues.apache.org/jira/browse/KAFKA-10129
Project: Kafka
Issue Type: Improve
[
https://issues.apache.org/jira/browse/KAFKA-10129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17129393#comment-17129393
]
Chia-Ping Tsai commented on KAFKA-10129:
The javadoc is a part of public publica
[
https://issues.apache.org/jira/browse/KAFKA-9800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Cheng Tan updated KAFKA-9800:
-
Description:
Design:
The main idea is to bookkeep the failed attempt. Currently, the retry backoff
has
[
https://issues.apache.org/jira/browse/KAFKA-9800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Cheng Tan updated KAFKA-9800:
-
Description:
Design:
The main idea is to bookkeep the failed attempt. Currently, the retry backoff
has
[
https://issues.apache.org/jira/browse/KAFKA-9800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Cheng Tan updated KAFKA-9800:
-
Description:
Design:
The main idea is to bookkeep the failed attempt. Currently, the retry backoff
has
hachikuji commented on pull request #8664:
URL: https://github.com/apache/kafka/pull/8664#issuecomment-640947926
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
[
https://issues.apache.org/jira/browse/KAFKA-10129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai updated KAFKA-10129:
---
Summary: Fail QA if there are javadoc warnings (was: Fail the QA if there
is javadoc error)
guozhangwang merged pull request #8788:
URL: https://github.com/apache/kafka/pull/8788
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
ableegoldman opened a new pull request #8835:
URL: https://github.com/apache/kafka/pull/8835
The total amount of memory per Percentiles metric is actually the
sizeInBytes * number of samples, where the default number of samples is 2.
There are also at least 2 Percentiles metrics per task (
mimaison commented on pull request #8312:
URL: https://github.com/apache/kafka/pull/8312#issuecomment-640882951
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please lo
C0urante commented on a change in pull request #8828:
URL: https://github.com/apache/kafka/pull/8828#discussion_r436881026
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/util/TopicAdmin.java
##
@@ -375,6 +383,152 @@ public boolean createTopic(NewTopic top
tombentley commented on pull request #8312:
URL: https://github.com/apache/kafka/pull/8312#issuecomment-640700423
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
ijuma commented on a change in pull request #8672:
URL: https://github.com/apache/kafka/pull/8672#discussion_r436791602
##
File path: core/src/main/scala/kafka/log/LogManager.scala
##
@@ -878,8 +936,7 @@ class LogManager(logDirs: Seq[File],
// Now that replica in sourc
jiameixie commented on pull request #8836:
URL: https://github.com/apache/kafka/pull/8836#issuecomment-641125571
@ijuma @huxihx @guozhangwang Call for a review. Do you think there is a good
place to update `joinStart `? Thanks.
-
guozhangwang merged pull request #8815:
URL: https://github.com/apache/kafka/pull/8815
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
dajac commented on a change in pull request #8672:
URL: https://github.com/apache/kafka/pull/8672#discussion_r436704800
##
File path: core/src/main/scala/kafka/log/LogCleanerManager.scala
##
@@ -273,7 +272,7 @@ private[log] class LogCleanerManager(val logDirs: Seq[File],
*
bbejeck merged pull request #8823:
URL: https://github.com/apache/kafka/pull/8823
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 to th
chia7712 commented on a change in pull request #8836:
URL: https://github.com/apache/kafka/pull/8836#discussion_r437177352
##
File path: core/src/main/scala/kafka/tools/ConsumerPerformance.scala
##
@@ -105,16 +105,14 @@ object ConsumerPerformance extends LazyLogging {
var
kkonstantine commented on pull request #8805:
URL: https://github.com/apache/kafka/pull/8805#issuecomment-640853227
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub a
dajac commented on pull request #8672:
URL: https://github.com/apache/kafka/pull/8672#issuecomment-641249326
@hachikuji I have made another pass on the PR based on your input. Could you
please have a second look at it? I am especially interested by getting your
view on the overall approach
gardnervickers commented on pull request #7929:
URL: https://github.com/apache/kafka/pull/7929#issuecomment-640691697
In 6152847, I changed the approach taken in this PR to move away from
managing the producer state snapshot file as part of the segment lifecycle.
This was done for two reas
kowshik commented on a change in pull request #8680:
URL: https://github.com/apache/kafka/pull/8680#discussion_r437124061
##
File path: core/src/main/scala/kafka/zk/ZkData.scala
##
@@ -81,17 +83,26 @@ object BrokerIdsZNode {
object BrokerInfo {
/**
- * Create a broker i
Lucent-Wong removed a comment on pull request #8453:
URL: https://github.com/apache/kafka/pull/8453#issuecomment-641192433
retest this please
This is an automated message from the Apache Git Service.
To respond to the message
sneakyburro commented on a change in pull request #8752:
URL: https://github.com/apache/kafka/pull/8752#discussion_r437317697
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilder.java
##
@@ -842,7 +842,14 @@ public synchroniz
kkonstantine commented on pull request #8453:
URL: https://github.com/apache/kafka/pull/8453#issuecomment-641102055
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log on
abbccdda commented on a change in pull request #8832:
URL: https://github.com/apache/kafka/pull/8832#discussion_r436913810
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java
##
@@ -147,6 +147,46 @@ public String toStr
ijuma commented on pull request #8802:
URL: https://github.com/apache/kafka/pull/8802#issuecomment-640721062
Request/response names are just labels for humans, so you can change them
without affecting compatibility.
This is
mjsax commented on a change in pull request #8833:
URL: https://github.com/apache/kafka/pull/8833#discussion_r436864561
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StandbyTask.java
##
@@ -108,13 +107,20 @@ public void completeRestoration()
guozhangwang commented on a change in pull request #8833:
URL: https://github.com/apache/kafka/pull/8833#discussion_r437090376
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/Task.java
##
@@ -125,40 +126,21 @@ public boolean isValidTransition(f
vvcephei commented on a change in pull request #8676:
URL: https://github.com/apache/kafka/pull/8676#discussion_r436755332
##
File path:
streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBStoreTest.java
##
@@ -237,25 +236,6 @@ public void
shouldNotRemoveSta
guozhangwang commented on a change in pull request #8834:
URL: https://github.com/apache/kafka/pull/8834#discussion_r437069073
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java
##
@@ -528,7 +528,6 @@ public void onFailure(
chia7712 commented on a change in pull request #8838:
URL: https://github.com/apache/kafka/pull/8838#discussion_r437289845
##
File path:
core/src/test/scala/unit/kafka/admin/TopicCommandWithAdminClientTest.scala
##
@@ -697,6 +697,10 @@ class TopicCommandWithAdminClientTest ext
guozhangwang commented on pull request #8676:
URL: https://github.com/apache/kafka/pull/8676#issuecomment-640892231
Merged to trunk and cherry-picked to 2.6
This is an automated message from the Apache Git Service.
To respond
bellemare commented on pull request #8764:
URL: https://github.com/apache/kafka/pull/8764#issuecomment-640926702
I swear it ran checkstyle when I compiled it... bah! I guess not. I did run
./gradlew :streams:test it had one unrelated error (I think) so lets see how it
does now.
-
tombentley commented on pull request #8839:
URL: https://github.com/apache/kafka/pull/8839#issuecomment-641201269
@kkonstantine please could you review this, thanks
This is an automated message from the Apache Git Service.
To
rhauch commented on a change in pull request #8805:
URL: https://github.com/apache/kafka/pull/8805#discussion_r436925315
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeAssignor.java
##
@@ -159,6 +163,13 @@ private
vvcephei commented on a change in pull request #8818:
URL: https://github.com/apache/kafka/pull/8818#discussion_r436758351
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java
##
@@ -1084,12 +1088,15 @@ private boolean
guozhangwang commented on pull request #8816:
URL: https://github.com/apache/kafka/pull/8816#issuecomment-640934122
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub a
feyman2016 commented on a change in pull request #8832:
URL: https://github.com/apache/kafka/pull/8832#discussion_r437529829
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java
##
@@ -147,6 +147,46 @@ public String toS
xvrl commented on pull request #8800:
URL: https://github.com/apache/kafka/pull/8800#issuecomment-640914664
@ijuma tested this change locally, broker starts up fine and gc logs show
up.
This is an automated message from the
wicknicks commented on a change in pull request #8829:
URL: https://github.com/apache/kafka/pull/8829#discussion_r436843713
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/RetryWithToleranceOperator.java
##
@@ -87,6 +87,12 @@ public RetryWit
mjsax merged pull request #8803:
URL: https://github.com/apache/kafka/pull/8803
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 to the
bellemare commented on a change in pull request #8764:
URL: https://github.com/apache/kafka/pull/8764#discussion_r436871862
##
File path:
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableKTableForeignKeyJoinScenarioTest.java
##
@@ -243,17 +244,17 @@ priva
abbccdda commented on a change in pull request #8822:
URL: https://github.com/apache/kafka/pull/8822#discussion_r436800666
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/SubscriptionState.java
##
@@ -1050,4 +1062,43 @@ public String toString()
msilb commented on pull request #1596:
URL: https://github.com/apache/kafka/pull/1596#issuecomment-641312887
I see the parent issue has been open since 2014. Any idea when this finally
is going to be implemented?
This is an
mjsax commented on pull request #8788:
URL: https://github.com/apache/kafka/pull/8788#issuecomment-640741662
Retest this please.
This is an automated message from the Apache Git Service.
To respond to the message, please log
kkonstantine commented on pull request #7384:
URL: https://github.com/apache/kafka/pull/7384#issuecomment-641103428
ok to test
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-9923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman updated KAFKA-9923:
---
Fix Version/s: (was: 2.6.0)
> Join window store duplicates can be compacted in ch
[
https://issues.apache.org/jira/browse/KAFKA-9923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman resolved KAFKA-9923.
Resolution: Not A Problem
[~cadonna] pointed out that this actually ins't a problem
mjsax commented on pull request #8803:
URL: https://github.com/apache/kafka/pull/8803#issuecomment-640934234
Merged to `trunk` and cherry-picked to `2.6` branch.
This is an automated message from the Apache Git Service.
To re
ijuma commented on a change in pull request #7929:
URL: https://github.com/apache/kafka/pull/7929#discussion_r436792477
##
File path: core/src/main/scala/kafka/log/Log.scala
##
@@ -2237,7 +2209,11 @@ class Log(@volatile private var _dir: File,
def deleteSegments(): Unit =
junrao commented on a change in pull request #8680:
URL: https://github.com/apache/kafka/pull/8680#discussion_r437049072
##
File path: core/src/main/scala/kafka/zk/ZkData.scala
##
@@ -81,17 +83,26 @@ object BrokerIdsZNode {
object BrokerInfo {
/**
- * Create a broker in
chia7712 opened a new pull request #8837:
URL: https://github.com/apache/kafka/pull/8837
When a reassignment is still in progress, the replica which is either
removing or adding should be considered to be under reassignment. However,
TopicCommand still print the partition which is removing
hachikuji merged pull request #8802:
URL: https://github.com/apache/kafka/pull/8802
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 to
vvcephei commented on pull request #8764:
URL: https://github.com/apache/kafka/pull/8764#issuecomment-640686536
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and u
Lucent-Wong commented on pull request #8453:
URL: https://github.com/apache/kafka/pull/8453#issuecomment-641192263
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub an
bbejeck commented on pull request #8823:
URL: https://github.com/apache/kafka/pull/8823#issuecomment-640729994
Merged #8823 into trunk.
This is an automated message from the Apache Git Service.
To respond to the message, plea
sneakyburro commented on pull request #8752:
URL: https://github.com/apache/kafka/pull/8752#issuecomment-640936812
> @sneakyburro -- Just a heads up: code freeze for 2.6 release in on
Wednesday. If you want to get the PR into the release, please address the
review comments soon. Otherwise,
ableegoldman commented on a change in pull request #8818:
URL: https://github.com/apache/kafka/pull/8818#discussion_r436825265
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
##
@@ -86,7 +87,7 @@
private boolean rebalanceI
mjsax commented on pull request #8752:
URL: https://github.com/apache/kafka/pull/8752#issuecomment-640935840
@sneakyburro -- Just a heads up: code freeze for 2.6 release in on
Wednesday. If you want to get the PR into the release, please address the
review comments soon. Otherwise, this wi
rgroothuijsen commented on a change in pull request #8664:
URL: https://github.com/apache/kafka/pull/8664#discussion_r436973523
##
File path:
clients/src/main/java/org/apache/kafka/clients/producer/internals/SenderMetricsRegistry.java
##
@@ -84,7 +84,7 @@ public SenderMetricsR
abbccdda commented on a change in pull request #8834:
URL: https://github.com/apache/kafka/pull/8834#discussion_r437110527
##
File path:
clients/src/test/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinatorTest.java
##
@@ -604,6 +605,25 @@ public void
testSync
chia7712 opened a new pull request #8838:
URL: https://github.com/apache/kafka/pull/8838
```TopicCommandWithAdminClientTest.testDescribeUnderReplicatedPartitionsWhenReassignmentIsInProgress```
fails frequently on my local.
### Committer Checklist (excluded from commit message)
-
omkreddy merged pull request #8800:
URL: https://github.com/apache/kafka/pull/8800
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 to t
Lucent-Wong edited a comment on pull request #8453:
URL: https://github.com/apache/kafka/pull/8453#issuecomment-641192263
Looks like the build failure is not related with my changes.
> Task :streams:test-utils:integrationTest
> Task :streams:upgrade-system-tests-0100:integr
kkonstantine commented on a change in pull request #8805:
URL: https://github.com/apache/kafka/pull/8805#discussion_r436950305
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeAssignor.java
##
@@ -159,6 +163,13 @@ p
guozhangwang merged pull request #8676:
URL: https://github.com/apache/kafka/pull/8676
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
hachikuji merged pull request #8783:
URL: https://github.com/apache/kafka/pull/8783
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 to
ableegoldman commented on a change in pull request #8676:
URL: https://github.com/apache/kafka/pull/8676#discussion_r436858916
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/ChangelogRegister.java
##
@@ -34,7 +34,6 @@
/**
* Unregist
mjsax commented on pull request #8821:
URL: https://github.com/apache/kafka/pull/8821#issuecomment-641022736
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
guozhangwang opened a new pull request #8834:
URL: https://github.com/apache/kafka/pull/8834
1. Allow the heartbeat thread to send hb request during rebalance; in turn
when handling responses if the state is not in STABLE ignore the error.
2. Piggy-backing a log4j improvement on the
bob-barrett commented on a change in pull request #8239:
URL: https://github.com/apache/kafka/pull/8239#discussion_r437077452
##
File path:
core/src/main/scala/kafka/coordinator/transaction/TransactionCoordinator.scala
##
@@ -487,6 +487,33 @@ class TransactionCoordinator(broke
feyman2016 opened a new pull request #8832:
URL: https://github.com/apache/kafka/pull/8832
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgrade
1 - 100 of 197 matches
Mail list logo
