feyman2016 opened a new pull request #9270:
URL: https://github.com/apache/kafka/pull/9270
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgrade note
chia7712 opened a new pull request #9271:
URL: https://github.com/apache/kafka/pull/9271
kafka.server.LinuxIoMetricsCollector -> kafka.metrics.LinuxIoMetricsCollector
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test
[
https://issues.apache.org/jira/browse/KAFKA-10253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17192798#comment-17192798
]
Goltseva Taisiia commented on KAFKA-10253:
--
Hi, guys!
We had the same problem.
[
https://issues.apache.org/jira/browse/KAFKA-10413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
BDeus updated KAFKA-10413:
--
Attachment: connect_worker_balanced.png
> rebalancing leads to unevenly balanced connectors
>
[
https://issues.apache.org/jira/browse/KAFKA-10413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17192827#comment-17192827
]
BDeus commented on KAFKA-10413:
---
I have this issue too when EC2 scale in (S3 sink connecto
[
https://issues.apache.org/jira/browse/KAFKA-10413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17192827#comment-17192827
]
BDeus edited comment on KAFKA-10413 at 9/9/20, 12:23 PM:
-
I have
[
https://issues.apache.org/jira/browse/KAFKA-10413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17192827#comment-17192827
]
BDeus edited comment on KAFKA-10413 at 9/9/20, 12:57 PM:
-
I have
[
https://issues.apache.org/jira/browse/KAFKA-10413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
BDeus updated KAFKA-10413:
--
Attachment: (was: connect_worker_balanced.png)
> rebalancing leads to unevenly balanced connectors
> -
[
https://issues.apache.org/jira/browse/KAFKA-10413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17192827#comment-17192827
]
BDeus edited comment on KAFKA-10413 at 9/9/20, 12:58 PM:
-
I have
[
https://issues.apache.org/jira/browse/KAFKA-10413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17192827#comment-17192827
]
BDeus edited comment on KAFKA-10413 at 9/9/20, 12:58 PM:
-
I have
[
https://issues.apache.org/jira/browse/KAFKA-10413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
BDeus updated KAFKA-10413:
--
Attachment: connect_worker_balanced.png
> rebalancing leads to unevenly balanced connectors
>
[
https://issues.apache.org/jira/browse/KAFKA-10413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17192827#comment-17192827
]
BDeus edited comment on KAFKA-10413 at 9/9/20, 1:00 PM:
I have t
[
https://issues.apache.org/jira/browse/KAFKA-10413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17192827#comment-17192827
]
BDeus edited comment on KAFKA-10413 at 9/9/20, 1:00 PM:
I have t
dajac opened a new pull request #9272:
URL: https://github.com/apache/kafka/pull/9272
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgrade n
dajac commented on pull request #9249:
URL: https://github.com/apache/kafka/pull/9249#issuecomment-689564871
@apovzner I have looked at this further and I have thought about another
approach. I have opened a PR for it: https://github.com/apache/kafka/pull/9272.
I hope that you don't mind.
t;TRACE")
Review comment:
@tombentley A small propsal: would
`org.apache.log4j.Level.TRACE.toString` be better?
It passes compilation checks.
> Add Regex option for replacement on MaskField SMT
> -
ijuma commented on a change in pull request #9202:
URL: https://github.com/apache/kafka/pull/9202#discussion_r485652591
##
File path:
core/src/main/scala/kafka/coordinator/group/GroupMetadataManager.scala
##
@@ -1401,24 +1401,20 @@ object GroupMetadataManager {
val vers
ijuma commented on a change in pull request #9223:
URL: https://github.com/apache/kafka/pull/9223#discussion_r485659670
##
File path:
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/record/RecordBatchIterationBenchmark.java
##
@@ -142,15 +169,15 @@ private ByteBuffer createB
chia7712 commented on a change in pull request #9223:
URL: https://github.com/apache/kafka/pull/9223#discussion_r48574
##
File path:
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/record/RecordBatchIterationBenchmark.java
##
@@ -142,15 +169,15 @@ private ByteBuffer crea
chia7712 commented on pull request #9257:
URL: https://github.com/apache/kafka/pull/9257#issuecomment-689608467
> Can you please add a comment explaining that git is included in openjdk:8,
but not openjdk:11?
done. Thanks for reviews!
---
ijuma merged pull request #9182:
URL: https://github.com/apache/kafka/pull/9182
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
[
https://issues.apache.org/jira/browse/KAFKA-10403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma resolved KAFKA-10403.
-
Fix Version/s: 2.7.0
Resolution: Fixed
> Replace scala collection by java collection in g
[
https://issues.apache.org/jira/browse/KAFKA-10468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma resolved KAFKA-10468.
-
Resolution: Duplicate
Duplicate of KAFKA-10403.
> Log4jController.getLoggers serialization
> --
[
https://issues.apache.org/jira/browse/KAFKA-10470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma updated KAFKA-10470:
Priority: Major (was: Minor)
> zstd decompression with small batches is slow and causes excessive
tombentley commented on a change in pull request #9266:
URL: https://github.com/apache/kafka/pull/9266#discussion_r485671503
##
File path: core/src/test/scala/kafka/utils/LoggingTest.scala
##
@@ -58,4 +60,20 @@ class LoggingTest extends Logging {
assertEquals(logging.get
dongjinleekr commented on a change in pull request #9266:
URL: https://github.com/apache/kafka/pull/9266#discussion_r485673100
##
File path: core/src/test/scala/kafka/utils/LoggingTest.scala
##
@@ -58,4 +60,20 @@ class LoggingTest extends Logging {
assertEquals(logging.g
ijuma commented on a change in pull request #9223:
URL: https://github.com/apache/kafka/pull/9223#discussion_r485675758
##
File path:
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/record/RecordBatchIterationBenchmark.java
##
@@ -142,15 +169,15 @@ private ByteBuffer createB
[
https://issues.apache.org/jira/browse/KAFKA-10304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ning Zhang updated KAFKA-10304:
---
Description:
In a different MM2 change, [some
concerns|https://github.com/apache/kafka/pull/9029#is
[
https://issues.apache.org/jira/browse/KAFKA-10304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17192664#comment-17192664
]
Ning Zhang edited comment on KAFKA-10304 at 9/9/20, 3:00 PM:
-
ning2008wisc commented on pull request #9224:
URL: https://github.com/apache/kafka/pull/9224#issuecomment-689622169
very appreciated for any feedback on what to test additionally and how to
get close to the real scenario. Some of the ideas come from
https://github.com/apache/kafka/blob/tru
rajinisivaram commented on pull request #9200:
URL: https://github.com/apache/kafka/pull/9200#issuecomment-689624548
@lbradstreet Thanks for the PR, merging to trunk.
This is an automated message from the Apache Git Service.
rajinisivaram merged pull request #9200:
URL: https://github.com/apache/kafka/pull/9200
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
bbejeck commented on a change in pull request #9221:
URL: https://github.com/apache/kafka/pull/9221#discussion_r48569
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StatefulProcessorNode.java
##
@@ -99,5 +99,14 @@ public void writeToTo
vvcephei commented on a change in pull request #9221:
URL: https://github.com/apache/kafka/pull/9221#discussion_r485732127
##
File path: streams/src/main/java/org/apache/kafka/streams/Topology.java
##
@@ -772,6 +806,94 @@ public synchronized Topology addStateStore(final
StoreB
John Roesler created KAFKA-10472:
Summary: Consider migrating Topology methods to the Builder pattern
Key: KAFKA-10472
URL: https://issues.apache.org/jira/browse/KAFKA-10472
Project: Kafka
Is
vvcephei commented on a change in pull request #9221:
URL: https://github.com/apache/kafka/pull/9221#discussion_r485735152
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/ProcessorParameters.java
##
@@ -26,22 +30,57 @@
* Used by the Join
vvcephei commented on a change in pull request #9221:
URL: https://github.com/apache/kafka/pull/9221#discussion_r485742765
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StatefulProcessorNode.java
##
@@ -99,5 +99,14 @@ public void writeToT
vvcephei commented on pull request #9221:
URL: https://github.com/apache/kafka/pull/9221#issuecomment-689669494
Thanks for the review @bbejeck ! I really appreciate your time.
I've responded to your feedback.
This is a
bbejeck commented on a change in pull request #9221:
URL: https://github.com/apache/kafka/pull/9221#discussion_r485754938
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StatefulProcessorNode.java
##
@@ -99,5 +99,14 @@ public void writeToTo
vvcephei commented on a change in pull request #9267:
URL: https://github.com/apache/kafka/pull/9267#discussion_r485759565
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
##
@@ -689,6 +644,7 @@ void runOnce() {
*
chia7712 commented on a change in pull request #9223:
URL: https://github.com/apache/kafka/pull/9223#discussion_r485761001
##
File path:
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/record/RecordBatchIterationBenchmark.java
##
@@ -142,15 +169,15 @@ private ByteBuffer crea
guozhangwang commented on a change in pull request #9267:
URL: https://github.com/apache/kafka/pull/9267#discussion_r485763899
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
##
@@ -689,6 +644,7 @@ void runOnce() {
vvcephei commented on a change in pull request #9267:
URL: https://github.com/apache/kafka/pull/9267#discussion_r485767592
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
##
@@ -752,6 +712,77 @@ void runOnce() {
commi
vvcephei commented on a change in pull request #9267:
URL: https://github.com/apache/kafka/pull/9267#discussion_r485771434
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
##
@@ -706,13 +662,17 @@ void runOnce() {
vvcephei commented on pull request #9267:
URL: https://github.com/apache/kafka/pull/9267#issuecomment-689702908
Thanks for the review, @wcarlson5 and @guozhangwang !
I've re-worded the logs to avoid internal class names and added the state
before calling restore. Aside from those cha
vvcephei commented on pull request #9221:
URL: https://github.com/apache/kafka/pull/9221#issuecomment-689703973
Thanks, @bbejeck ! Just to be sure, I'm merging trunk into this branch and
running all the tests before I squash-and-merge.
-
vvcephei merged pull request #9221:
URL: https://github.com/apache/kafka/pull/9221
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
apovzner closed pull request #9249:
URL: https://github.com/apache/kafka/pull/9249
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
apovzner commented on pull request #9249:
URL: https://github.com/apache/kafka/pull/9249#issuecomment-689715022
@dajac I like your approach better. I will close this PR.
This is an automated message from the Apache Git Servic
vvcephei commented on pull request #9267:
URL: https://github.com/apache/kafka/pull/9267#issuecomment-689715414
Thanks, @guozhangwang !
This is an automated message from the Apache Git Service.
To respond to the message, plea
[
https://issues.apache.org/jira/browse/KAFKA-10467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17193116#comment-17193116
]
Swayam Raina commented on KAFKA-10467:
--
Any idea what causes this?
Also, can anyone
mjsax merged pull request #9157:
URL: https://github.com/apache/kafka/pull/9157
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
jonhkr commented on pull request #9256:
URL: https://github.com/apache/kafka/pull/9256#issuecomment-689757461
@ijuma Could you take a look?
This is an automated message from the Apache Git Service.
To respond to the message,
wcarlson5 opened a new pull request #9273:
URL: https://github.com/apache/kafka/pull/9273
Adding an option to shutdown an entire streams application for a Streams
thread
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify
mjsax commented on a change in pull request #9156:
URL: https://github.com/apache/kafka/pull/9156#discussion_r485846736
##
File path:
clients/src/main/java/org/apache/kafka/server/authorizer/AuthorizableRequestContext.java
##
@@ -17,11 +17,12 @@
package org.apache.kafka.ser
lkokhreidze commented on a change in pull request #9237:
URL: https://github.com/apache/kafka/pull/9237#discussion_r485885898
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilder.java
##
@@ -632,8 +632,18 @@ public final void
lkokhreidze commented on a change in pull request #9237:
URL: https://github.com/apache/kafka/pull/9237#discussion_r485886423
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/StreamTableJoinTopologyOptimizationIntegrationTest.java
##
@@ -0,0 +1,242 @@
+
lkokhreidze commented on pull request #9237:
URL: https://github.com/apache/kafka/pull/9237#issuecomment-689788570
call for review @mjsax @vvcephei @guozhangwang @bbejeck
This is an automated message from the Apache Git Serv
[
https://issues.apache.org/jira/browse/KAFKA-10454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17193155#comment-17193155
]
Levani Kokhreidze commented on KAFKA-10454:
---
Hey [~vvcephei] thanks for the fe
wcarlson5 commented on a change in pull request #9273:
URL: https://github.com/apache/kafka/pull/9273#discussion_r485857758
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java
##
@@ -1436,6 +1447,16 @@ public void onAs
lkokhreidze commented on a change in pull request #9237:
URL: https://github.com/apache/kafka/pull/9237#discussion_r485885898
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilder.java
##
@@ -632,8 +632,18 @@ public final void
lkokhreidze commented on a change in pull request #9237:
URL: https://github.com/apache/kafka/pull/9237#discussion_r485885898
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilder.java
##
@@ -632,8 +632,18 @@ public final void
lkokhreidze commented on pull request #9237:
URL: https://github.com/apache/kafka/pull/9237#issuecomment-689804031
Ran `./gradlew :streams:clean :streams:test` locally, everything passed.
This is an automated message from the
rondagostino opened a new pull request #9274:
URL: https://github.com/apache/kafka/pull/9274
Eliminate "use_zk_connection" and similarly-named flags in public system
test methods. System tests should always use admin client when the broker
supports it. We do need to bootstrap ACLs prior
[
https://issues.apache.org/jira/browse/KAFKA-10213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17193175#comment-17193175
]
Ron Dagostino commented on KAFKA-10213:
---
Fixes included in PR for https://issues.a
[
https://issues.apache.org/jira/browse/KAFKA-10258?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17193178#comment-17193178
]
Ron Dagostino commented on KAFKA-10258:
---
Fixes included in PR for https://issues.a
cmccabe commented on pull request #9274:
URL: https://github.com/apache/kafka/pull/9274#issuecomment-689824902
Thanks, @rondagostino . Is there any way to avoid moving the acls stuff out
of `kafka_acls.py`? It seems nice to have some separation rather than having
everything in `kafka.py`
guozhangwang commented on pull request #9237:
URL: https://github.com/apache/kafka/pull/9237#issuecomment-689825230
test this please
This is an automated message from the Apache Git Service.
To respond to the message, please
ableegoldman commented on a change in pull request #9239:
URL: https://github.com/apache/kafka/pull/9239#discussion_r485927114
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java
##
@@ -150,23 +152,46 @@ public void
hachikuji opened a new pull request #9275:
URL: https://github.com/apache/kafka/pull/9275
This patch bumps the `Fetch` protocol as specified by KIP-595:
https://cwiki.apache.org/confluence/display/KAFKA/KIP-595%3A+A+Raft+Protocol+for+the+Metadata+Quorum.
The main differences are the follow
junrao merged pull request #8657:
URL: https://github.com/apache/kafka/pull/8657
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
[
https://issues.apache.org/jira/browse/KAFKA-8334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao reassigned KAFKA-8334:
--
Fix Version/s: 2.7.0
Assignee: Chia-Ping Tsai
Resolution: Fixed
Merged the PR to trunk
junrao commented on pull request #8657:
URL: https://github.com/apache/kafka/pull/8657#issuecomment-689838971
@chia7712 : Thanks a lot for staying on this tricky issue and finding a
simpler solution!
This is an automated mes
guozhangwang commented on pull request #9247:
URL: https://github.com/apache/kafka/pull/9247#issuecomment-689840075
test this please
This is an automated message from the Apache Git Service.
To respond to the message, please
guozhangwang commented on a change in pull request #9247:
URL: https://github.com/apache/kafka/pull/9247#discussion_r485941828
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java
##
@@ -662,4 +662,10 @@ public TopicPartit
James Cheng created KAFKA-10473:
---
Summary: Website is missing docs on JMX metrics for partition
size-on-disk
Key: KAFKA-10473
URL: https://issues.apache.org/jira/browse/KAFKA-10473
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-10473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
James Cheng updated KAFKA-10473:
Summary: Website is missing docs on JMX metrics for partition size-on-disk
(kafka.log:type=Log,nam
wushujames opened a new pull request #9276:
URL: https://github.com/apache/kafka/pull/9276
Add docs on the following JMX metrics
kafka.log,type=Log,name=Size
kafka.log,type=Log,name=NumLogSegments
kafka.log,type=Log,name=LogStartOffset
kafka.log,type=Log,name=LogEndOffset
wushujames commented on a change in pull request #9276:
URL: https://github.com/apache/kafka/pull/9276#discussion_r485955266
##
File path: docs/ops.html
##
@@ -1129,6 +1128,26 @@ Security
Considerations for Remote Mon
kafka.server:type=BrokerTopicMetrics,name=Reassig
wushujames commented on a change in pull request #9276:
URL: https://github.com/apache/kafka/pull/9276#discussion_r485955567
##
File path: docs/ops.html
##
@@ -1129,6 +1128,26 @@ Security
Considerations for Remote Mon
kafka.server:type=BrokerTopicMetrics,name=Reassig
wushujames commented on a change in pull request #9276:
URL: https://github.com/apache/kafka/pull/9276#discussion_r485956062
##
File path: docs/ops.html
##
@@ -1129,6 +1128,26 @@ Security
Considerations for Remote Mon
kafka.server:type=BrokerTopicMetrics,name=Reassig
[
https://issues.apache.org/jira/browse/KAFKA-10473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
James Cheng reassigned KAFKA-10473:
---
Assignee: James Cheng
> Website is missing docs on JMX metrics for partition size-on-disk
wushujames commented on pull request #9276:
URL: https://github.com/apache/kafka/pull/9276#issuecomment-689856879
@guozhangwang Can I get a review?
This is an automated message from the Apache Git Service.
To respond to t
rondagostino commented on pull request #9274:
URL: https://github.com/apache/kafka/pull/9274#issuecomment-689862257
@cmccabe Thanks for the review. I put the logic back into `kafka_acls.py`.
Take a look and let me know if this is what you were thinking.
-
junrao commented on a change in pull request #9178:
URL: https://github.com/apache/kafka/pull/9178#discussion_r485958438
##
File path: core/src/main/scala/kafka/server/ReplicaManager.scala
##
@@ -1698,8 +1698,12 @@ class ReplicaManager(val config: KafkaConfig,
Partition.re
hachikuji opened a new pull request #9277:
URL: https://github.com/apache/kafka/pull/9277
The schema specification allows a struct type name to differ from the field
name. This works with the generated `Message` classes, but not with the
generated JSON converter. The problem seems to be th
cmccabe merged pull request #9269:
URL: https://github.com/apache/kafka/pull/9269
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
cmccabe commented on pull request #9277:
URL: https://github.com/apache/kafka/pull/9277#issuecomment-689896549
LGTM
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
[
https://issues.apache.org/jira/browse/KAFKA-10467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17193292#comment-17193292
]
Luke Chen commented on KAFKA-10467:
---
> Any idea what causes this?
-> Sorry, I cannot
[
https://issues.apache.org/jira/browse/KAFKA-10170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17193293#comment-17193293
]
Chia-Ping Tsai commented on KAFKA-10170:
This is addressed by
https://github.co
[
https://issues.apache.org/jira/browse/KAFKA-10170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-10170.
Resolution: Duplicate
> ReplicaManager should be responsible for checking delayed operatio
chia7712 commented on pull request #8657:
URL: https://github.com/apache/kafka/pull/8657#issuecomment-689921735
> Thanks a lot for staying on this tricky issue and finding a simpler
solution!
thanks for all suggestions. I benefit a lot from it.
-
chia7712 opened a new pull request #9278:
URL: https://github.com/apache/kafka/pull/9278
inspired by https://github.com/apache/kafka/pull/8657#discussion_r484092945
```
With this change, DelayedOperations.checkAndCompleteFetch() is only used in
tests. I am wondering if it can be r
1 - 100 of 107 matches
Mail list logo
