ableegoldman commented on a change in pull request #10755:
URL: https://github.com/apache/kafka/pull/10755#discussion_r639350604
##
File path: docs/streams/upgrade-guide.html
##
@@ -117,6 +117,14 @@ Streams API
We removed the default implementation of
A. Sophie Blee-Goldman created KAFKA-12849:
--
Summary: Consider migrating TaskMetadata to interface with
internal implementation
Key: KAFKA-12849
URL: https://issues.apache.org/jira/browse/KAFKA-12849
[
https://issues.apache.org/jira/browse/KAFKA-12849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17351440#comment-17351440
]
A. Sophie Blee-Goldman commented on KAFKA-12849:
Though we went through a similar
ableegoldman commented on a change in pull request #10755:
URL: https://github.com/apache/kafka/pull/10755#discussion_r639355330
##
File path: streams/src/main/java/org/apache/kafka/streams/processor/TaskId.java
##
@@ -80,6 +83,35 @@ public String toString() {
return
ableegoldman commented on a change in pull request #10755:
URL: https://github.com/apache/kafka/pull/10755#discussion_r639358536
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/TaskMetadata.java
##
@@ -40,6 +40,18 @@
private final Optional
ableegoldman commented on a change in pull request #10755:
URL: https://github.com/apache/kafka/pull/10755#discussion_r639351170
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/TaskMetadata.java
##
@@ -40,6 +40,18 @@
private final Optional
vahidhashemian commented on pull request #10552:
URL: https://github.com/apache/kafka/pull/10552#issuecomment-848436761
Thanks for addressing my comments @showuon. I tested a couple of unit tests
and saw the difference this change makes.
I have no further comment at this time. Given
showuon commented on pull request #10552:
URL: https://github.com/apache/kafka/pull/10552#issuecomment-848453397
@vahidhashemian , thank you for your review! :)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
ableegoldman commented on a change in pull request #10755:
URL: https://github.com/apache/kafka/pull/10755#discussion_r639356381
##
File path: streams/src/main/java/org/apache/kafka/streams/processor/TaskId.java
##
@@ -80,6 +83,35 @@ public String toString() {
return
ableegoldman commented on a change in pull request #10745:
URL: https://github.com/apache/kafka/pull/10745#discussion_r639358048
##
File path:
streams/src/test/java/org/apache/kafka/streams/kstream/internals/SlidingWindowedCogroupedKStreamImplTest.java
##
@@ -169,34 +167,37
[
https://issues.apache.org/jira/browse/KAFKA-9168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17351444#comment-17351444
]
Sagar Rao commented on KAFKA-9168:
--
Sure thanks. Probably, I will send a patch for one of the APIs
[
https://issues.apache.org/jira/browse/KAFKA-12848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-12848:
-
Assignee: Sagar Rao
> Add some basic benchmarks for Kafka Streams
>
socutes commented on a change in pull request #10749:
URL: https://github.com/apache/kafka/pull/10749#discussion_r638494789
##
File path: raft/src/main/java/org/apache/kafka/raft/FileBasedStateStore.java
##
@@ -91,14 +92,22 @@ private QuorumStateData readStateFromFile(File
socutes commented on a change in pull request #10749:
URL: https://github.com/apache/kafka/pull/10749#discussion_r638499447
##
File path: raft/src/main/java/org/apache/kafka/raft/FileBasedStateStore.java
##
@@ -67,7 +68,7 @@ public FileBasedStateStore(final File stateFile) {
KahnCheny commented on pull request #10746:
URL: https://github.com/apache/kafka/pull/10746#issuecomment-847563816
Thanks
--
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 specific comment.
showuon commented on pull request #10552:
URL: https://github.com/apache/kafka/pull/10552#issuecomment-847807953
@vahidhashemian , thanks for the comments. I've updated. Please take a look
again. Thank you.
--
This is an automated message from the Apache Git Service.
To respond to the
ryannedolan commented on pull request #10762:
URL: https://github.com/apache/kafka/pull/10762#issuecomment-847906780
thx lgtm!
--
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 specific
ijuma opened a new pull request #10759:
URL: https://github.com/apache/kafka/pull/10759
New parameters in overloaded methods should appear later apart from
lambdas that should always be last.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and
dongjinleekr commented on pull request #10428:
URL: https://github.com/apache/kafka/pull/10428#issuecomment-847885818
Rebased onto the latest trunk. cc/ @cadonna
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
dongjinleekr commented on pull request #9414:
URL: https://github.com/apache/kafka/pull/9414#issuecomment-847886290
Hi @guozhangwang @vvcephei,
Could you have a look now? :smiley:
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
dajac commented on a change in pull request #10757:
URL: https://github.com/apache/kafka/pull/10757#discussion_r638806738
##
File path: core/src/main/scala/kafka/log/Log.scala
##
@@ -2011,7 +2011,11 @@ object Log extends Logging {
logDirFailureChannel,
mdedetrich opened a new pull request #10762:
URL: https://github.com/apache/kafka/pull/10762
This PR does various QoL improvements for the MM tests, mainly some basic
refactoring to remove some boilerplate as well as adding messages to all of the
assert statements so that if they fail
socutes commented on a change in pull request #10749:
URL: https://github.com/apache/kafka/pull/10749#discussion_r638535599
##
File path: raft/src/main/java/org/apache/kafka/raft/QuorumState.java
##
@@ -116,7 +117,7 @@ public void initialize(OffsetAndEpoch
socutes commented on a change in pull request #10749:
URL: https://github.com/apache/kafka/pull/10749#discussion_r638542877
##
File path: raft/src/test/java/org/apache/kafka/raft/QuorumStateTest.java
##
@@ -945,9 +945,7 @@ public void testObserverUnattachedToFollower() throws
[
https://issues.apache.org/jira/browse/KAFKA-12847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Abhijit Mane updated KAFKA-12847:
-
Description:
Hello,
I tried apache/kafka system tests as per documentation: -
[
https://issues.apache.org/jira/browse/KAFKA-12847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Abhijit Mane updated KAFKA-12847:
-
Description:
Hello,
I tried apache/kafka system tests as per documentation: -
[
https://issues.apache.org/jira/browse/KAFKA-12743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17351000#comment-17351000
]
Sergey Zyrianov commented on KAFKA-12743:
-
I don't think uReplicator alternative is relevant. It
jlprat opened a new pull request #10758:
URL: https://github.com/apache/kafka/pull/10758
This is just a workaround to solve this problem while we are still using
JDK11.
Once moving to, presumably, JDK17 this change won't be needed
anymore and could be deleted safely. See
[
https://issues.apache.org/jira/browse/KAFKA-12800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot reassigned KAFKA-12800:
---
Assignee: (was: David Jacot)
> Configure jackson to to reject trailing input in the
[
https://issues.apache.org/jira/browse/KAFKA-12800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot reassigned KAFKA-12800:
---
Assignee: David Jacot
> Configure jackson to to reject trailing input in the generator
>
ijuma commented on a change in pull request #10757:
URL: https://github.com/apache/kafka/pull/10757#discussion_r638837477
##
File path: core/src/main/scala/kafka/log/Log.scala
##
@@ -2011,7 +2011,11 @@ object Log extends Logging {
logDirFailureChannel,
[
https://issues.apache.org/jira/browse/KAFKA-12782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17351001#comment-17351001
]
Josep Prat commented on KAFKA-12782:
I can confirm this is bug with Java11 for API docs that do not
dajac opened a new pull request #10757:
URL: https://github.com/apache/kafka/pull/10757
This patch logs more information when a producer snapshot is written to the
disk.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify
dajac merged pull request #10717:
URL: https://github.com/apache/kafka/pull/10717
--
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 specific comment.
For queries about this service, please
thomaskwscott opened a new pull request #10760:
URL: https://github.com/apache/kafka/pull/10760
See
https://cwiki.apache.org/confluence/display/KAFKA/KIP-734%3A+Improve+AdminClient.listOffsets+to+return+timestamp+and+offset+for+the+record+with+the+largest+timestamp
*More detailed
showuon commented on a change in pull request #10552:
URL: https://github.com/apache/kafka/pull/10552#discussion_r638718719
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java
##
@@ -637,19 +709,27 @@ private void
jlprat commented on pull request #10758:
URL: https://github.com/apache/kafka/pull/10758#issuecomment-847839591
cc @ableegoldman as you opened the Jira ticket, maybe you'd like to review
this one?
--
This is an automated message from the Apache Git Service.
To respond to the message,
dajac commented on a change in pull request #10616:
URL: https://github.com/apache/kafka/pull/10616#discussion_r638764893
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/internals/AllBrokersStrategy.java
##
@@ -0,0 +1,212 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/KAFKA-12800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot resolved KAFKA-12800.
-
Fix Version/s: 3.0.0
Resolution: Fixed
Author: Nathan Lincoln
> Configure jackson to to
ijuma commented on pull request #10761:
URL: https://github.com/apache/kafka/pull/10761#issuecomment-847881296
cc @jolshan
--
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 specific comment.
ijuma opened a new pull request #10761:
URL: https://github.com/apache/kafka/pull/10761
Log if deletion fails and don't expose log topic id for mutability outside
of `assignTopicId()`.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
ijuma commented on a change in pull request #10757:
URL: https://github.com/apache/kafka/pull/10757#discussion_r638803061
##
File path: core/src/main/scala/kafka/log/Log.scala
##
@@ -2011,7 +2011,11 @@ object Log extends Logging {
logDirFailureChannel,
dajac commented on pull request #10760:
URL: https://github.com/apache/kafka/pull/10760#issuecomment-847883470
I will review it in the next few days.
--
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
[
https://issues.apache.org/jira/browse/KAFKA-12430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17351093#comment-17351093
]
Matthew de Detrich commented on KAFKA-12430:
[~ryannedolan] I am going to look into this, do
[
https://issues.apache.org/jira/browse/KAFKA-12430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthew de Detrich reassigned KAFKA-12430:
--
Assignee: Matthew de Detrich
> emit.heartbeats.enabled = false should
ableegoldman commented on pull request #10755:
URL: https://github.com/apache/kafka/pull/10755#issuecomment-848407312
Addressed your comments @mjsax
--
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
[
https://issues.apache.org/jira/browse/KAFKA-9295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17351457#comment-17351457
]
Luke Chen commented on KAFKA-9295:
--
On it!
>
chia7712 opened a new pull request #10764:
URL: https://github.com/apache/kafka/pull/10764
I'm migrating Ranger's kafka plugin from deprecated Authorizer (this is
already removed by 976e78e405d57943b989ac487b7f49119b0f4af4) to new API (see
[
https://issues.apache.org/jira/browse/KAFKA-12822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17350862#comment-17350862
]
Josep Prat commented on KAFKA-12822:
As [~mjsax] pointed out, some of this sub-tasks may not be able
[
https://issues.apache.org/jira/browse/KAFKA-12824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17350941#comment-17350941
]
Bruno Cadonna commented on KAFKA-12824:
---
[~mjsax] Do we know for which date AK 4.0.0 is planned? I
[
https://issues.apache.org/jira/browse/KAFKA-5676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17350960#comment-17350960
]
Bruno Cadonna commented on KAFKA-5676:
--
[~marcolotz] Thank you for looking into this!
The classes
rajinisivaram commented on pull request #10377:
URL: https://github.com/apache/kafka/pull/10377#issuecomment-847762942
@feyman2016 We should add `ignorable=true` for the fields added for feature
support in
`clients/src/main/resources/common/message/ApiVersionsResponse.json`. This
would
tombentley commented on pull request #10750:
URL: https://github.com/apache/kafka/pull/10750#issuecomment-847768625
It's unlikely that 2.5 or 2.6 will see another release, but I've backported
it to the 2.7 branch so it's in any 2.7.2 which gets released.
--
This is an automated message
socutes commented on a change in pull request #10749:
URL: https://github.com/apache/kafka/pull/10749#discussion_r638535599
##
File path: raft/src/main/java/org/apache/kafka/raft/QuorumState.java
##
@@ -116,7 +117,7 @@ public void initialize(OffsetAndEpoch
[
https://issues.apache.org/jira/browse/KAFKA-12846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17350904#comment-17350904
]
Luke Chen commented on KAFKA-12846:
---
[~ws], I believe the comments in else block answers your
[
https://issues.apache.org/jira/browse/KAFKA-12461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
loboxu reassigned KAFKA-12461:
--
Assignee: (was: loboxu)
> Extend LogManager to cover the metadata topic
>
DuongPTIT commented on pull request #10670:
URL: https://github.com/apache/kafka/pull/10670#issuecomment-847730974
hi @showuon, please take a review. Thank you so much!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
DuongPTIT removed a comment on pull request #10670:
URL: https://github.com/apache/kafka/pull/10670#issuecomment-840464740
--
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 specific comment.
[
https://issues.apache.org/jira/browse/KAFKA-12824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17350942#comment-17350942
]
Josep Prat commented on KAFKA-12824:
On the parent issue there is this sentence:
> Each subtask
dengziming commented on pull request #10701:
URL: https://github.com/apache/kafka/pull/10701#issuecomment-847753120
@mjsax @guozhangwang , how do you think about this approach? In fact, I'm
not very confident about this change since it isn't very elegant, but this can
remove the TODO,
[
https://issues.apache.org/jira/browse/KAFKA-5676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17350960#comment-17350960
]
Bruno Cadonna edited comment on KAFKA-5676 at 5/25/21, 10:42 AM:
-
socutes commented on a change in pull request #10749:
URL: https://github.com/apache/kafka/pull/10749#discussion_r638494789
##
File path: raft/src/main/java/org/apache/kafka/raft/FileBasedStateStore.java
##
@@ -91,14 +92,22 @@ private QuorumStateData readStateFromFile(File
kowshik commented on pull request #10756:
URL: https://github.com/apache/kafka/pull/10756#issuecomment-847620694
cc @junrao @ijuma @chia7712 for review
--
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
kowshik opened a new pull request #10756:
URL: https://github.com/apache/kafka/pull/10756
Have done a small improvement in this PR by flipping logical NOT for
readability. Basically, the following code:
```
if (A) {
if (B) {
} else {
}
} else if (B) {
}
```
socutes commented on a change in pull request #10749:
URL: https://github.com/apache/kafka/pull/10749#discussion_r638537574
##
File path: raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java
##
@@ -372,27 +371,23 @@ private void maybeFireLeaderChange() {
DuongPTIT commented on pull request #10750:
URL: https://github.com/apache/kafka/pull/10750#issuecomment-847728426
> Please confirm if the issue only happen in V2.5 or newer release. If also
happen in trunk, please make the merge target as `trunk` (and fix based on the
`trunk` branch),
[
https://issues.apache.org/jira/browse/KAFKA-12847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Abhijit Mane updated KAFKA-12847:
-
Description:
Hello,
I tried apache/kafka system tests as per documentation: -
[
https://issues.apache.org/jira/browse/KAFKA-12824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17350859#comment-17350859
]
Josep Prat commented on KAFKA-12824:
I know that some of the ones I created might not be able to be
socutes commented on a change in pull request #10749:
URL: https://github.com/apache/kafka/pull/10749#discussion_r638536001
##
File path: raft/src/main/java/org/apache/kafka/raft/FileBasedStateStore.java
##
@@ -91,14 +92,17 @@ private QuorumStateData readStateFromFile(File
showuon commented on a change in pull request #10749:
URL: https://github.com/apache/kafka/pull/10749#discussion_r638544356
##
File path: raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java
##
@@ -372,27 +371,23 @@ private void maybeFireLeaderChange() {
DuongPTIT edited a comment on pull request #10750:
URL: https://github.com/apache/kafka/pull/10750#issuecomment-847728426
> Please confirm if the issue only happen in V2.5 or newer release. If also
happen in trunk, please make the merge target as `trunk` (and fix based on the
`trunk`
showuon commented on a change in pull request #10552:
URL: https://github.com/apache/kafka/pull/10552#discussion_r638654728
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java
##
@@ -469,73 +426,190 @@ private boolean
tombentley commented on pull request #10750:
URL: https://github.com/apache/kafka/pull/10750#issuecomment-847746044
Probably fixed by https://github.com/apache/kafka/pull/9735
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
DuongPTIT commented on pull request #10750:
URL: https://github.com/apache/kafka/pull/10750#issuecomment-847756554
> Probably fixed by #9735
I've seen that this issue still happen in V2.5, V2.6, V2.7. What about these
versions? Do they need to fix this similar to V2.8 and trunk?
[
https://issues.apache.org/jira/browse/KAFKA-12782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Josep Prat reassigned KAFKA-12782:
--
Assignee: Josep Prat
> Javadocs search sends you to a non-existent URL
>
showuon commented on a change in pull request #10749:
URL: https://github.com/apache/kafka/pull/10749#discussion_r638513347
##
File path: raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java
##
@@ -372,27 +371,23 @@ private void maybeFireLeaderChange() {
socutes commented on a change in pull request #10749:
URL: https://github.com/apache/kafka/pull/10749#discussion_r638542037
##
File path: raft/src/main/java/org/apache/kafka/raft/QuorumState.java
##
@@ -116,7 +117,7 @@ public void initialize(OffsetAndEpoch
showuon commented on pull request #10750:
URL: https://github.com/apache/kafka/pull/10750#issuecomment-847654763
@DuongPTIT , thanks for the PR. One important question to you before
reviewing the code: could you confirm this issue only happen in V2.5, and not
V2.8? I'm not sure if we will
socutes commented on a change in pull request #10749:
URL: https://github.com/apache/kafka/pull/10749#discussion_r638556812
##
File path: raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java
##
@@ -372,27 +371,23 @@ private void maybeFireLeaderChange() {
kowshik closed pull request #9764:
URL: https://github.com/apache/kafka/pull/9764
--
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 specific comment.
For queries about this service, please
[
https://issues.apache.org/jira/browse/KAFKA-10846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tom Bentley updated KAFKA-10846:
Fix Version/s: 2.7.2
> FileStreamSourceTask buffer can grow without bound
>
[
https://issues.apache.org/jira/browse/KAFKA-12847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Abhijit Mane updated KAFKA-12847:
-
Description:
Hello,
I tried apache/kafka system tests as per documentation: -
[
https://issues.apache.org/jira/browse/KAFKA-12847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Abhijit Mane updated KAFKA-12847:
-
Description:
Hello,
I tried apache/kafka system tests as per documentation: -
showuon commented on a change in pull request #10749:
URL: https://github.com/apache/kafka/pull/10749#discussion_r638511262
##
File path: raft/src/main/java/org/apache/kafka/raft/FileBasedStateStore.java
##
@@ -67,7 +68,7 @@ public FileBasedStateStore(final File stateFile) {
kowshik commented on a change in pull request #10684:
URL: https://github.com/apache/kafka/pull/10684#discussion_r638519831
##
File path: core/src/main/scala/kafka/log/LogSegments.scala
##
@@ -210,11 +209,23 @@ class LogSegments(topicPartition: TopicPartition) {
* @return
kowshik commented on a change in pull request #10684:
URL: https://github.com/apache/kafka/pull/10684#discussion_r638520142
##
File path: core/src/main/scala/kafka/log/Log.scala
##
@@ -1217,10 +1213,8 @@ class Log(@volatile private var _dir: File,
fetchDataInfo =
kowshik commented on a change in pull request #10684:
URL: https://github.com/apache/kafka/pull/10684#discussion_r638520142
##
File path: core/src/main/scala/kafka/log/Log.scala
##
@@ -1217,10 +1213,8 @@ class Log(@volatile private var _dir: File,
fetchDataInfo =
DuongPTIT commented on pull request #10750:
URL: https://github.com/apache/kafka/pull/10750#issuecomment-847644863
hi @showuon, can you please review this for me?
Many thanks
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
yws created KAFKA-12846:
---
Summary: why need this logic in Consumer‘s Fetch logic it should
remove?
Key: KAFKA-12846
URL: https://issues.apache.org/jira/browse/KAFKA-12846
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-10900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
loboxu reassigned KAFKA-10900:
--
Assignee: loboxu
> Add metrics enumerated in KIP-630
> -
>
>
showuon commented on a change in pull request #10552:
URL: https://github.com/apache/kafka/pull/10552#discussion_r638651011
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java
##
@@ -444,23 +392,32 @@ private boolean
showuon commented on a change in pull request #10552:
URL: https://github.com/apache/kafka/pull/10552#discussion_r638655936
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java
##
@@ -637,19 +709,27 @@ private void
Abhijit Mane created KAFKA-12847:
Summary: Dockerfile needed for kafka system tests needs changes
Key: KAFKA-12847
URL: https://issues.apache.org/jira/browse/KAFKA-12847
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-12511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17351159#comment-17351159
]
Josep Prat edited comment on KAFKA-12511 at 5/25/21, 4:00 PM:
--
Seen in:
[
https://issues.apache.org/jira/browse/KAFKA-9009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17351155#comment-17351155
]
Josep Prat commented on KAFKA-9009:
---
Seen in
[
https://issues.apache.org/jira/browse/KAFKA-12319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17351161#comment-17351161
]
Josep Prat commented on KAFKA-12319:
Failed again in
[
https://issues.apache.org/jira/browse/KAFKA-9295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17351166#comment-17351166
]
Josep Prat commented on KAFKA-9295:
---
Seen it in
[
https://issues.apache.org/jira/browse/KAFKA-12430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17351104#comment-17351104
]
Ryanne Dolan commented on KAFKA-12430:
--
Hmm. I guess the downside to not creating the topics is
[
https://issues.apache.org/jira/browse/KAFKA-12511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17351159#comment-17351159
]
Josep Prat commented on KAFKA-12511:
Seen in:
jlprat commented on pull request #10758:
URL: https://github.com/apache/kafka/pull/10758#issuecomment-847997038
Test failures were known flaky tests. Added a comment on the corresponding
Jira's
--
This is an automated message from the Apache Git Service.
To respond to the message,
1 - 100 of 119 matches
Mail list logo
