chia7712 commented on pull request #9162:
URL: https://github.com/apache/kafka/pull/9162#issuecomment-689963179
@ijuma I have attached test result and ```NonLocalReturnException``` is
gone. Please take a look.
This is an
chia7712 commented on pull request #9278:
URL: https://github.com/apache/kafka/pull/9278#issuecomment-689937879
@junrao FYI
This is an automated message from the Apache Git Service.
To respond to the message, please log on
chia7712 commented on a change in pull request #9278:
URL: https://github.com/apache/kafka/pull/9278#discussion_r486027311
##
File path: core/src/test/scala/unit/kafka/cluster/PartitionTest.scala
##
@@ -922,102 +918,6 @@ class PartitionTest extends AbstractPartitionTest {
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
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.
[
https://issues.apache.org/jira/browse/KAFKA-10170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17193293#comment-17193293
]
Chia-Ping Tsai commented on KAFKA-10170:
This is addressed by
[
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
[
https://issues.apache.org/jira/browse/KAFKA-10467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17193292#comment-17193292
]
Luke Chen commented on KAFKA-10467:
---
> Any idea what causes this?
-> Sorry, I cannot reproduce it in
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
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
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
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,
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.
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
[
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 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
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
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
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
[
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
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
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
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
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
[
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
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
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
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
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
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
[
https://issues.apache.org/jira/browse/KAFKA-10258?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17193178#comment-17193178
]
Ron Dagostino commented on KAFKA-10258:
---
Fixes included in PR for
[
https://issues.apache.org/jira/browse/KAFKA-10213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17193175#comment-17193175
]
Ron Dagostino commented on KAFKA-10213:
---
Fixes included in PR for
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
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
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
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
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
[
https://issues.apache.org/jira/browse/KAFKA-10454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17193155#comment-17193155
]
Levani Kokhreidze commented on KAFKA-10454:
---
Hey [~vvcephei] thanks for the feedback.
Finally
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
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 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
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
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
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,
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
[
https://issues.apache.org/jira/browse/KAFKA-10467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17193116#comment-17193116
]
Swayam Raina commented on KAFKA-10467:
--
Any idea what causes this?
Also, can anyone provide an
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,
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
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
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
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 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
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 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() {
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() {
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
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() {
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
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
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
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_r485732127
##
File path: streams/src/main/java/org/apache/kafka/streams/Topology.java
##
@@ -772,6 +806,94 @@ public synchronized Topology addStateStore(final
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
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
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
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.
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://issues.apache.org/jira/browse/KAFKA-10304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17192664#comment-17192664
]
Ning Zhang edited comment on KAFKA-10304 at 9/9/20, 3:00 PM:
-
Hi [~mimaison]
[
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
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
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 {
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 {
[
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
[
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-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
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
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!
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
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
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
[
https://issues.apache.org/jira/browse/KAFKA-10466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dongjin Lee updated KAFKA-10466:
Labels: Needs-kip newbie (was: )
> Add Regex option for replacement on MaskField SMT
>
ijuma commented on pull request #9178:
URL: https://github.com/apache/kafka/pull/9178#issuecomment-689590729
@junrao maybe you can review this.
This is an automated message from the Apache Git Service.
To respond to the
ijuma commented on pull request #9257:
URL: https://github.com/apache/kafka/pull/9257#issuecomment-689590183
Thanks for the PR. Can you please add a comment explaining that `git` is
included in openjdk:8, but not openjdk:11?
[
https://issues.apache.org/jira/browse/KAFKA-10284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17192885#comment-17192885
]
feyman commented on KAFKA-10284:
Just FYI, created a PR: https://github.com/apache/kafka/pull/9270
>
lct45 commented on a change in pull request #9239:
URL: https://github.com/apache/kafka/pull/9239#discussion_r485623786
##
File path:
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KGroupedStreamImplTest.java
##
@@ -239,52 +241,81 @@ private void
lct45 commented on a change in pull request #9239:
URL: https://github.com/apache/kafka/pull/9239#discussion_r485621499
##
File path:
streams/src/test/java/org/apache/kafka/streams/kstream/internals/SlidingWindowedCogroupedKStreamImplTest.java
##
@@ -246,4 +238,31 @@ private
lct45 commented on a change in pull request #9239:
URL: https://github.com/apache/kafka/pull/9239#discussion_r485620554
##
File path:
streams/src/test/java/org/apache/kafka/streams/kstream/internals/SuppressScenarioTest.java
##
@@ -493,52 +494,59 @@ public void
t;TRACE")
Review comment:
@tombentley A small propsal: would
`org.apache.log4j.Level.TRACE.toString` be better?
It passes compilation checks.
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgrade
[
https://issues.apache.org/jira/browse/KAFKA-10413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17192827#comment-17192827
]
BDeus edited comment on KAFKA-10413 at 9/9/20, 1:00 PM:
I have this issue too
[
https://issues.apache.org/jira/browse/KAFKA-10413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17192827#comment-17192827
]
BDeus edited comment on KAFKA-10413 at 9/9/20, 1:00 PM:
I have this issue too
[
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=17192827#comment-17192827
]
BDeus edited comment on KAFKA-10413 at 9/9/20, 12:58 PM:
-
I have this issue too
[
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=17192827#comment-17192827
]
BDeus edited comment on KAFKA-10413 at 9/9/20, 12:58 PM:
-
I have this issue too
[
https://issues.apache.org/jira/browse/KAFKA-10413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17192827#comment-17192827
]
BDeus edited comment on KAFKA-10413 at 9/9/20, 12:57 PM:
-
I have this issue too
[
https://issues.apache.org/jira/browse/KAFKA-10413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17192827#comment-17192827
]
BDeus commented on KAFKA-10413:
---
I have this issue too when EC2 scale in (S3 sink connector).
It seems
[
https://issues.apache.org/jira/browse/KAFKA-10413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17192827#comment-17192827
]
BDeus edited comment on KAFKA-10413 at 9/9/20, 12:23 PM:
-
I have this issue too
[
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
>
1 - 100 of 110 matches
Mail list logo
