cadonna commented on pull request #9191:
URL: https://github.com/apache/kafka/pull/9191#issuecomment-685407069
Test this please
This is an automated message from the Apache Git Service.
To respond to the message, please log o
chia7712 commented on pull request #9102:
URL: https://github.com/apache/kafka/pull/9102#issuecomment-685408584
@guozhangwang @abbccdda ping ~
This is an automated message from the Apache Git Service.
To respond to the messag
omkreddy commented on a change in pull request #9236:
URL: https://github.com/apache/kafka/pull/9236#discussion_r481854947
##
File path:
clients/src/main/java/org/apache/kafka/common/security/kerberos/KerberosLogin.java
##
@@ -237,6 +238,7 @@ public LoginContext login() throws
cnZach commented on a change in pull request #9236:
URL: https://github.com/apache/kafka/pull/9236#discussion_r481880310
##
File path:
clients/src/main/java/org/apache/kafka/common/security/kerberos/KerberosLogin.java
##
@@ -237,6 +238,7 @@ public LoginContext login() throws L
omkreddy commented on pull request #9236:
URL: https://github.com/apache/kafka/pull/9236#issuecomment-685444628
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
jeqo commented on a change in pull request #9138:
URL: https://github.com/apache/kafka/pull/9138#discussion_r481920572
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/ReadOnlyWindowStore.java
##
@@ -33,11 +33,11 @@
/**
* Get the value of key from
jeqo commented on a change in pull request #9138:
URL: https://github.com/apache/kafka/pull/9138#discussion_r481930378
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractMergedSortedCacheStoreIterator.java
##
@@ -192,4 +192,3 @@ public void cl
jeqo commented on a change in pull request #9138:
URL: https://github.com/apache/kafka/pull/9138#discussion_r481931127
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractSegments.java
##
@@ -117,12 +118,20 @@ public void openExisting(final Pro
manijndl7 opened a new pull request #9244:
URL: https://github.com/apache/kafka/pull/9244
*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 testing
big-andy-coates commented on pull request #9156:
URL: https://github.com/apache/kafka/pull/9156#issuecomment-685493474
@guozhangwang @mjsax ready for another review.
This is an automated message from the Apache Git Service.
T
[
https://issues.apache.org/jira/browse/KAFKA-6585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17188984#comment-17188984
]
Mani Jindal edited comment on KAFKA-6585 at 9/2/20, 9:30 AM:
-
huxihx merged pull request #9240:
URL: https://github.com/apache/kafka/pull/9240
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
huxihx commented on pull request #9240:
URL: https://github.com/apache/kafka/pull/9240#issuecomment-685535337
@omkreddy Thanks for the review, merging to trunk.
This is an automated message from the Apache Git Service.
To res
[
https://issues.apache.org/jira/browse/KAFKA-10456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
huxihx resolved KAFKA-10456.
Fix Version/s: 2.7.0
Resolution: Fixed
> wrong description in kafka-console-producer.sh help
>
mimaison commented on pull request #8050:
URL: https://github.com/apache/kafka/pull/8050#issuecomment-685557805
Ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
LMnet commented on a change in pull request #8955:
URL: https://github.com/apache/kafka/pull/8955#discussion_r481972046
##
File path:
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/serialization/Serdes.scala
##
@@ -43,12 +43,6 @@ object Serdes extends LowP
LMnet commented on pull request #8955:
URL: https://github.com/apache/kafka/pull/8955#issuecomment-685598623
@chia7712 ok, I will check this. I think I know how to fix this.
This is an automated message from the Apache Git Se
[
https://issues.apache.org/jira/browse/KAFKA-9440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17189158#comment-17189158
]
Sandeep Kumar commented on KAFKA-9440:
--
h4. [@Boyang Chen
|https://issues.apache.or
LMnet opened a new pull request #9245:
URL: https://github.com/apache/kafka/pull/9245
This is a build fix after
[KAFKA-10020](https://github.com/apache/kafka/pull/8955).
It looks like scala 2.12 and 2.13 have different import shadowing
algorithms. On 2.12 explicit import of
`org.a
LMnet commented on pull request #8955:
URL: https://github.com/apache/kafka/pull/8955#issuecomment-685686014
@chia7712 I created a fix: https://github.com/apache/kafka/pull/9245
This is an automated message from the Apache Gi
chia7712 commented on pull request #9245:
URL: https://github.com/apache/kafka/pull/9245#issuecomment-685713654
> It looks like scala 2.12 and 2.13 have different import shadowing
algorithms. On 2.12 explicit import of
org.apache.kafka.streams.scala.serialization.Serdes has less priority t
lct45 commented on a change in pull request #9157:
URL: https://github.com/apache/kafka/pull/9157#discussion_r482078343
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java
##
@@ -254,35 +257,43 @@ private void proce
lct45 commented on a change in pull request #9157:
URL: https://github.com/apache/kafka/pull/9157#discussion_r482079220
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java
##
@@ -192,29 +191,113 @@ public void proce
lct45 commented on a change in pull request #9157:
URL: https://github.com/apache/kafka/pull/9157#discussion_r482084851
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java
##
@@ -311,13 +322,8 @@ private void putAnd
mumrah opened a new pull request #9246:
URL: https://github.com/apache/kafka/pull/9246
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
jeqo commented on a change in pull request #9138:
URL: https://github.com/apache/kafka/pull/9138#discussion_r482127067
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/SegmentIterator.java
##
@@ -67,14 +70,22 @@ public Bytes peekNextKey() {
pub
bbejeck commented on pull request #9208:
URL: https://github.com/apache/kafka/pull/9208#issuecomment-685789082
@khaireddine120 can you rebase this PR against trunk? Then after the build
we can get this merged.
This is an aut
bbejeck commented on pull request #9209:
URL: https://github.com/apache/kafka/pull/9209#issuecomment-685789732
@khaireddine120 can you rebase this PR against trunk? Then after the build
we can get this merged.
This is an aut
bbejeck commented on pull request #9207:
URL: https://github.com/apache/kafka/pull/9207#issuecomment-685790819
@khaireddine120 can you rebase this PR against trunk? Then after the build
we can get this merged.
This is an aut
jeqo commented on a change in pull request #9138:
URL: https://github.com/apache/kafka/pull/9138#discussion_r482160020
##
File path: streams/src/main/java/org/apache/kafka/streams/state/WindowStore.java
##
@@ -150,13 +185,25 @@
* @return an iterator over windowed key-valu
mimaison merged pull request #8798:
URL: https://github.com/apache/kafka/pull/8798
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
jeqo commented on a change in pull request #9138:
URL: https://github.com/apache/kafka/pull/9138#discussion_r482160859
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/ReadOnlyWindowStore.java
##
@@ -136,34 +174,64 @@
*
* This iterator must be cl
[
https://issues.apache.org/jira/browse/KAFKA-10098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison resolved KAFKA-10098.
Fix Version/s: 2.7.0
Resolution: Fixed
> Remove unnecessary escaping in regular exp
mimaison commented on pull request #8798:
URL: https://github.com/apache/kafka/pull/8798#issuecomment-685814537
Thanks for the PR @cancecen
This is an automated message from the Apache Git Service.
To respond to the message,
[
https://issues.apache.org/jira/browse/KAFKA-10272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison resolved KAFKA-10272.
Fix Version/s: 2.7.0
Resolution: Fixed
> kafka-server-stop.sh fails on IBM i
>
mimaison merged pull request #9023:
URL: https://github.com/apache/kafka/pull/9023
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
junrao commented on pull request #8657:
URL: https://github.com/apache/kafka/pull/8657#issuecomment-685831526
@chia7712 It seems there are some compilation errors in jenkins?
https://ci-builds.apache.org/job/Kafka/job/kafka-pr/view/change-requests/job/PR-8657/1/consoleFull
`
chia7712 commented on pull request #8657:
URL: https://github.com/apache/kafka/pull/8657#issuecomment-685833800
> 00:31:51 [Error]
/home/jenkins/jenkins-agent/workspace/Kafka_kafka-pr_PR-8657/streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/StreamToTableJoinScalaIntegrati
mimaison merged pull request #8050:
URL: https://github.com/apache/kafka/pull/8050
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
chia7712 commented on pull request #8657:
URL: https://github.com/apache/kafka/pull/8657#issuecomment-685837334
```kafka.network.DynamicConnectionQuotaTest.testDynamicListenerConnectionCreationRateQuota```
pass on my local. retest this please
-
chia7712 commented on pull request #8657:
URL: https://github.com/apache/kafka/pull/8657#issuecomment-685838009
Retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please lo
mimaison commented on pull request #9122:
URL: https://github.com/apache/kafka/pull/9122#issuecomment-685841902
@nresare Good catch! The change looks good.
Before merging I'd like to get this change tested in the CI pipeline. The
Apache Jenkins setup just changed a few days ago and
mimaison commented on a change in pull request #9215:
URL: https://github.com/apache/kafka/pull/9215#discussion_r482195986
##
File path: connect/mirror/README.md
##
@@ -141,7 +141,38 @@ nearby clusters.
N.B. that the `--clusters` parameter is not technically required here. MM2
ijuma commented on pull request #9245:
URL: https://github.com/apache/kafka/pull/9245#issuecomment-685846486
We should merge this to fix the build, but it seems suboptimal for our users
too. cc @guozhangwang @mjsax @vvcephei
---
nresare commented on pull request #9122:
URL: https://github.com/apache/kafka/pull/9122#issuecomment-685846761
@mimaison Thanks for having a look! I just rebased and pushed and it seems
there are checks being kicked off as well 🎉
--
mimaison commented on pull request #8730:
URL: https://github.com/apache/kafka/pull/8730#issuecomment-685847906
Thanks @asdaraujo, I'll try to take another look later on this week.
Can you rebase on trunk? to pick up a change
(https://github.com/apache/kafka/commit/241e1447fae8b85b3b
chia7712 commented on a change in pull request #9246:
URL: https://github.com/apache/kafka/pull/9246#discussion_r482211220
##
File path: Jenkinsfile
##
@@ -31,6 +31,25 @@ def doValidation() {
spotlessScalaCheck checkstyleMain checkstyleTest spotbugsMain rat \
[
https://issues.apache.org/jira/browse/KAFKA-10129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-10129.
Resolution: Won't Fix
> Fail QA if there are javadoc warnings
> --
chia7712 closed pull request #8840:
URL: https://github.com/apache/kafka/pull/8840
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
chia7712 closed pull request #9185:
URL: https://github.com/apache/kafka/pull/9185
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
ning2008wisc commented on a change in pull request #9215:
URL: https://github.com/apache/kafka/pull/9215#discussion_r482214035
##
File path: connect/mirror/README.md
##
@@ -141,7 +141,38 @@ nearby clusters.
N.B. that the `--clusters` parameter is not technically required here.
LMnet commented on pull request #9245:
URL: https://github.com/apache/kafka/pull/9245#issuecomment-685863455
@ijuma kafka users will not be affected by this, because shadowing conflict
occurs only in the kafka internal packages.
---
ableegoldman commented on a change in pull request #9157:
URL: https://github.com/apache/kafka/pull/9157#discussion_r482234612
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java
##
@@ -311,13 +322,8 @@ private void
vvcephei commented on a change in pull request #9191:
URL: https://github.com/apache/kafka/pull/9191#discussion_r482250207
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/HandlingSourceTopicDeletionTest.java
##
@@ -0,0 +1,109 @@
+/*
+ * License
vvcephei commented on pull request #9245:
URL: https://github.com/apache/kafka/pull/9245#issuecomment-685893240
Retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please lo
vvcephei commented on pull request #9245:
URL: https://github.com/apache/kafka/pull/9245#issuecomment-685893473
Test this please
This is an automated message from the Apache Git Service.
To respond to the message, please log
vvcephei commented on pull request #9245:
URL: https://github.com/apache/kafka/pull/9245#issuecomment-685895615
Thanks for the reviews, all. I also took a look at the builds, and they seem
fine apart from the flaky tests.
Th
vvcephei merged pull request #9245:
URL: https://github.com/apache/kafka/pull/9245
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
vvcephei commented on pull request #9245:
URL: https://github.com/apache/kafka/pull/9245#issuecomment-685897537
Ok, I just merged this. Sorry for breaking the build, all. And thanks
@mumrah for getting the PR builds working again!
--
vvcephei commented on pull request #8955:
URL: https://github.com/apache/kafka/pull/8955#issuecomment-685904266
Thanks for pointing that out, @chia7712 , and sorry for breaking the build.
This is an automated message from the
DOJI45 opened a new pull request #9247:
URL: https://github.com/apache/kafka/pull/9247
What was the issue?
https://issues.apache.org/jira/browse/KAFKA-10362
Deleted the checkpoint file before the transition from SUSPENDED state to
RESTORING state
### Committer Checklist (e
lct45 opened a new pull request #9248:
URL: https://github.com/apache/kafka/pull/9248
Updated number of expected messages
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify
[
https://issues.apache.org/jira/browse/KAFKA-8764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17189628#comment-17189628
]
James Cheng commented on KAFKA-8764:
[~junrao], in the comment
https://issues.apache
[
https://issues.apache.org/jira/browse/KAFKA-10362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17189629#comment-17189629
]
Sharath Bhat commented on KAFKA-10362:
--
Hi [~guozhang],
I worked on the bug and h
ableegoldman commented on a change in pull request #9157:
URL: https://github.com/apache/kafka/pull/9157#discussion_r482297669
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java
##
@@ -192,29 +213,127 @@ public voi
asdaraujo commented on pull request #8730:
URL: https://github.com/apache/kafka/pull/8730#issuecomment-685935118
Thanks, @mimaison . I've rebased it.
This is an automated message from the Apache Git Service.
To respond to the
lct45 commented on a change in pull request #9157:
URL: https://github.com/apache/kafka/pull/9157#discussion_r482324434
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java
##
@@ -192,29 +213,127 @@ public void proce
vvcephei commented on pull request #9234:
URL: https://github.com/apache/kafka/pull/9234#issuecomment-685944151
Thanks, all!
This is an automated message from the Apache Git Service.
To respond to the message, please log on t
vvcephei commented on pull request #9234:
URL: https://github.com/apache/kafka/pull/9234#issuecomment-685946978
Retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please lo
rondagostino commented on pull request #9032:
URL: https://github.com/apache/kafka/pull/9032#issuecomment-685957655
System test run was successful except for 2 known flaky tests.
https://confluent-kafka-branch-builder-system-test-results.s3-us-west-2.amazonaws.com/2020-09-02--001.159907492
nresare commented on pull request #9122:
URL: https://github.com/apache/kafka/pull/9122#issuecomment-685964373
Trying to navigate the tests, it seems they are related to flakiness in
other parts of the overall test suite. Is it possible to re-trigger tests?
---
[
https://issues.apache.org/jira/browse/KAFKA-8764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17189684#comment-17189684
]
Jun Rao commented on KAFKA-8764:
[~wushujames]: Yes, reassigned replica can have the same
[
https://issues.apache.org/jira/browse/KAFKA-10409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Oleksandr Bondarenko reassigned KAFKA-10409:
Assignee: Oleksandr Bondarenko
> Refactor Kafka Streams RocksDb iterators
rondagostino commented on pull request #9032:
URL: https://github.com/apache/kafka/pull/9032#issuecomment-685977755
Test failures are flakes/unrelated to this PR, no overlaps across JDKs.
This is an automated message from the
vvcephei commented on pull request #9221:
URL: https://github.com/apache/kafka/pull/9221#issuecomment-685985893
Note: this is part 3 of KIP-478.
Part 1: #9004
Part 2: #9148
This is an automated message from the Apache G
[
https://issues.apache.org/jira/browse/KAFKA-10362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17189711#comment-17189711
]
Matthias J. Sax commented on KAFKA-10362:
-
[~DOJI], even if the ticket was not a
ableegoldman commented on a change in pull request #9239:
URL: https://github.com/apache/kafka/pull/9239#discussion_r482435367
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java
##
@@ -180,41 +217,225 @@ public voi
ableegoldman commented on pull request #9248:
URL: https://github.com/apache/kafka/pull/9248#issuecomment-686044360
One unrelated test failed:
`Build / JDK 8 / testNoConnectionLimitsByDefault –
kafka.network.ConnectionQuotasTest`
Also, why are there so many different builds now?
ableegoldman edited a comment on pull request #9248:
URL: https://github.com/apache/kafka/pull/9248#issuecomment-686044360
One unrelated test failed:
`Build / JDK 8 / testNoConnectionLimitsByDefault –
kafka.network.ConnectionQuotasTest`
Also, why are there so many different builds
[
https://issues.apache.org/jira/browse/KAFKA-10323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Randall Hauch updated KAFKA-10323:
--
Labels: newbie (was: )
> NullPointerException during rebalance
>
[
https://issues.apache.org/jira/browse/KAFKA-10273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Randall Hauch updated KAFKA-10273:
--
Labels: newbie (was: )
> Connect Converters should produce actionable error messages
> --
[
https://issues.apache.org/jira/browse/KAFKA-10366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17189725#comment-17189725
]
Matthias J. Sax edited comment on KAFKA-10366 at 9/2/20, 9:58 PM:
[
https://issues.apache.org/jira/browse/KAFKA-10366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17189725#comment-17189725
]
Matthias J. Sax commented on KAFKA-10366:
-
SGTM. And no worries about naming. It
guozhangwang commented on a change in pull request #9138:
URL: https://github.com/apache/kafka/pull/9138#discussion_r482524622
##
File path: streams/src/main/java/org/apache/kafka/streams/state/WindowStore.java
##
@@ -150,13 +185,25 @@
* @return an iterator over windowed
guozhangwang commented on a change in pull request #9138:
URL: https://github.com/apache/kafka/pull/9138#discussion_r482526159
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractSegments.java
##
@@ -117,12 +118,20 @@ public void openExisting(f
guozhangwang commented on a change in pull request #9138:
URL: https://github.com/apache/kafka/pull/9138#discussion_r482525737
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/ReadOnlyWindowStore.java
##
@@ -136,34 +174,64 @@
*
* This iterator mu
guozhangwang commented on a change in pull request #9138:
URL: https://github.com/apache/kafka/pull/9138#discussion_r480473830
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/SegmentIterator.java
##
@@ -67,14 +70,22 @@ public Bytes peekNextKey() {
guozhangwang commented on a change in pull request #9138:
URL: https://github.com/apache/kafka/pull/9138#discussion_r482528601
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/CachingWindowStore.java
##
@@ -338,25 +452,36 @@ public synchronized void
guozhangwang merged pull request #9138:
URL: https://github.com/apache/kafka/pull/9138
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
vvcephei commented on pull request #9248:
URL: https://github.com/apache/kafka/pull/9248#issuecomment-686058224
Yep, that looks like the only test that failed. Thanks, @ableegoldman .
Yes, the checks output leaves something to be desired. I don't know how
easy/possible it is to impro
vvcephei merged pull request #9248:
URL: https://github.com/apache/kafka/pull/9248
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
guozhangwang merged pull request #9232:
URL: https://github.com/apache/kafka/pull/9232
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-10448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17189767#comment-17189767
]
Matthias J. Sax commented on KAFKA-10448:
-
Just added you to the wiki.
{quote}Ne
mjsax commented on pull request #9244:
URL: https://github.com/apache/kafka/pull/9244#issuecomment-686152827
@brary Wanna help reviewing this PR?
This is an automated message from the Apache Git Service.
To respond to the mes
guozhangwang commented on pull request #9234:
URL: https://github.com/apache/kafka/pull/9234#issuecomment-686177562
LGTM!
This is an automated message from the Apache Git Service.
To respond to the message, please log on to G
[
https://issues.apache.org/jira/browse/KAFKA-10448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17189790#comment-17189790
]
satya commented on KAFKA-10448:
---
Thank you. I submitted the KIP-669. Please let me know if
ableegoldman commented on a change in pull request #8892:
URL: https://github.com/apache/kafka/pull/8892#discussion_r482678606
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ClientState.java
##
@@ -288,17 +288,17 @@ public void comp
ableegoldman commented on a change in pull request #8892:
URL: https://github.com/apache/kafka/pull/8892#discussion_r482678606
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ClientState.java
##
@@ -288,17 +288,17 @@ public void comp
[
https://issues.apache.org/jira/browse/KAFKA-10362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17189831#comment-17189831
]
Sharath Bhat commented on KAFKA-10362:
--
Hi [~ipasynkov],
Can I continue work on t
brary commented on pull request #9244:
URL: https://github.com/apache/kafka/pull/9244#issuecomment-686244886
> @brary Wanna help reviewing this PR?
Sure @mjsax, would be happy to pitch in.
This is an automated message
1 - 100 of 106 matches
Mail list logo
