[
https://issues.apache.org/jira/browse/KAFKA-9915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17214496#comment-17214496
]
David Jacot commented on KAFKA-9915:
[~bbejeck] Sure. Let me resolve it. I will updat
[
https://issues.apache.org/jira/browse/KAFKA-9915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot resolved KAFKA-9915.
Resolution: Fixed
> Throttle Create Topic, Create Partition and Delete Topic Operations
> -
tombentley commented on pull request #9422:
URL: https://github.com/apache/kafka/pull/9422#issuecomment-708974318
@kkonstantine thanks for taking a look, now sorted.
This is an automated message from the Apache Git Service.
T
ijuma opened a new pull request #9440:
URL: https://github.com/apache/kafka/pull/9440
This release includes a key fix:
* Zinc leaks its dependencies to user classpath
(https://github.com/gradle/gradle/issues/14168)
Release notes:
https://docs.gradle.org/6.7/release-notes.html
[
https://issues.apache.org/jira/browse/KAFKA-10614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tom Bentley reassigned KAFKA-10614:
---
Assignee: Tom Bentley
> Group coordinator onElection/onResignation should guard against lea
dongjinleekr commented on a change in pull request #9414:
URL: https://github.com/apache/kafka/pull/9414#discussion_r505424665
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateDirectory.java
##
@@ -301,6 +301,22 @@ public synchronized void
mimaison commented on a change in pull request #9313:
URL: https://github.com/apache/kafka/pull/9313#discussion_r505426022
##
File path:
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorConnectorConfig.java
##
@@ -199,6 +199,8 @@
protected static final
dongjinleekr edited a comment on pull request #9414:
URL: https://github.com/apache/kafka/pull/9414#issuecomment-709135091
@vvcephei
> it seems like we could improve the test coverage by checking that we get
the warning and do not delete the state dir if it's not empty.
Totall
dongjinleekr commented on pull request #9414:
URL: https://github.com/apache/kafka/pull/9414#issuecomment-709135091
> it seems like we could improve the test coverage by checking that we get
the warning and do not delete the state dir if it's not empty.
Totally agree. So, I added two
tombentley opened a new pull request #9441:
URL: https://github.com/apache/kafka/pull/9441
Implements the single thread with FIFO approach suggested in
https://issues.apache.org/jira/browse/KAFKA-10614
This is an automated m
tombentley commented on pull request #9441:
URL: https://github.com/apache/kafka/pull/9441#issuecomment-709225396
@guozhangwang this is a draft implementation of one of the solutions you
suggested. I will try to add a test, but in the meantime any comments you have
are welcome.
[
https://issues.apache.org/jira/browse/KAFKA-10590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sandeep p updated KAFKA-10590:
--
Description:
Whole cluster hungs when one of the three node goes down. To bring the cluster
back all
dengziming opened a new pull request #9442:
URL: https://github.com/apache/kafka/pull/9442
Just as `grantingVoters()` and `rejectingVoters()`, `unrecordedVoters()`
method be optimezed by using `votersInState(State)`
This is
dengziming commented on pull request #9442:
URL: https://github.com/apache/kafka/pull/9442#issuecomment-709269033
@hachikuji , PTAL
This is an automated message from the Apache Git Service.
To respond to the message, please
scanterog commented on a change in pull request #9313:
URL: https://github.com/apache/kafka/pull/9313#discussion_r505512942
##
File path:
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorMakerConfig.java
##
@@ -245,10 +254,17 @@ public MirrorClientConfig clie
xakassi commented on pull request #9431:
URL: https://github.com/apache/kafka/pull/9431#issuecomment-709301342
Hi, @kkonstantine !
Seems one test failed, but I can't see why. It's not likely that my changes
make it fail. Maybe we should rerun the tests? But I suppose I have no
permissio
[
https://issues.apache.org/jira/browse/KAFKA-7421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17214685#comment-17214685
]
Goltseva Taisiia commented on KAFKA-7421:
-
Hi, [~kleiby] !
Let me describe my is
[
https://issues.apache.org/jira/browse/KAFKA-7421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17214685#comment-17214685
]
Goltseva Taisiia edited comment on KAFKA-7421 at 10/15/20, 1:30 PM:
---
cadonna commented on a change in pull request #9416:
URL: https://github.com/apache/kafka/pull/9416#discussion_r505572558
##
File path: core/src/main/scala/kafka/coordinator/group/GroupCoordinator.scala
##
@@ -908,6 +908,7 @@ class GroupCoordinator(val brokerId: Int,
* @par
cadonna commented on a change in pull request #9416:
URL: https://github.com/apache/kafka/pull/9416#discussion_r505588367
##
File path: core/src/main/scala/kafka/coordinator/group/GroupCoordinator.scala
##
@@ -908,6 +908,7 @@ class GroupCoordinator(val brokerId: Int,
* @par
ijuma commented on pull request #9440:
URL: https://github.com/apache/kafka/pull/9440#issuecomment-709381048
JDK 15 flaky test failure is unrelated:
> StateDirectoryTest.shouldCleanupObsoleteStateDirectoriesOnlyOnce
Other builds passed.
---
ijuma merged pull request #9440:
URL: https://github.com/apache/kafka/pull/9440
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
lct45 commented on pull request #9383:
URL: https://github.com/apache/kafka/pull/9383#issuecomment-709396656
> Why do we use a size-1 byte array instead of a single byte for this field?
@vvcephei There's a `RecordsFieldType` already created for `byte[]` but not
one for `byte` so to get t
[
https://issues.apache.org/jira/browse/KAFKA-8531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17214773#comment-17214773
]
Gary Russell commented on KAFKA-8531:
-
The docs for default.replication.factor should
lct45 edited a comment on pull request #9383:
URL: https://github.com/apache/kafka/pull/9383#issuecomment-709396656
> Why do we use a size-1 byte array instead of a single byte for this field?
@vvcephei There's a `RecordsFieldType` already created for `byte[]` but not
one for `byte`
scanterog commented on pull request #9313:
URL: https://github.com/apache/kafka/pull/9313#issuecomment-709412233
> Thanks @scanterog, the changes look good now. I've left a couple of very
minor comments that would be nice to address. I'll be happy to merge then
Thanks. There's one te
scanterog edited a comment on pull request #9313:
URL: https://github.com/apache/kafka/pull/9313#issuecomment-709412233
> Thanks @scanterog, the changes look good now. I've left a couple of very
minor comments that would be nice to address. I'll be happy to merge then
Thanks. There's
mimaison commented on pull request #9313:
URL: https://github.com/apache/kafka/pull/9313#issuecomment-709415966
@scanterog I've rekicked the build
This is an automated message from the Apache Git Service.
To respond to the me
rondagostino opened a new pull request #9443:
URL: https://github.com/apache/kafka/pull/9443
*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 test
rondagostino commented on pull request #9443:
URL: https://github.com/apache/kafka/pull/9443#issuecomment-709427515
@rajinisivaram could you review?
All 9 system tests pass:
http://confluent-kafka-branch-builder-system-test-results.s3-us-west-2.amazonaws.com/2020-10-15--001.160277674
rajinisivaram merged pull request #9443:
URL: https://github.com/apache/kafka/pull/9443
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
rajinisivaram commented on pull request #9443:
URL: https://github.com/apache/kafka/pull/9443#issuecomment-709429966
Merging to trunk without waiting for builds since this is only changing a
system test.
This is an automated
hachikuji commented on pull request #9441:
URL: https://github.com/apache/kafka/pull/9441#issuecomment-709432283
@tombentley Thanks for the patch. I think the problem is in the callback
inside `KafkaApis.handleLeaderAndIsrRequest`. With two concurrent
`LeaderAndIsr` requests, there is no g
mimaison commented on pull request #9343:
URL: https://github.com/apache/kafka/pull/9343#issuecomment-709434733
@kkonstantine @rhauch can you take a look?
This is an automated message from the Apache Git Service.
To respond t
[
https://issues.apache.org/jira/browse/KAFKA-10472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17214818#comment-17214818
]
Matthias J. Sax commented on KAFKA-10472:
-
You need to create an account (note t
tombentley commented on pull request #9441:
URL: https://github.com/apache/kafka/pull/9441#issuecomment-709439774
@hachikuji, yes I see that although replica manager might be synchronized it
doesn't prevent the race. I was already working on introducing the epoch into
the group coordinator
[
https://issues.apache.org/jira/browse/KAFKA-8531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17214819#comment-17214819
]
Matthias J. Sax commented on KAFKA-8531:
[~grussell] of course. Note thought, tha
hachikuji commented on a change in pull request #9434:
URL: https://github.com/apache/kafka/pull/9434#discussion_r505678344
##
File path: core/src/main/scala/kafka/cluster/Partition.scala
##
@@ -1162,6 +1162,13 @@ class Partition(val topicPartition: TopicPartition,
localLo
guozhangwang closed pull request #9011:
URL: https://github.com/apache/kafka/pull/9011
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go
hachikuji commented on pull request #9441:
URL: https://github.com/apache/kafka/pull/9441#issuecomment-709447330
@tombentley Actually I missed the holding of the `replicaStateChangeLock`
inside `ReplicaManager.becomeLeaderOrFollower`. So the reordering I suggested
above seems not possible.
guozhangwang commented on pull request #9084:
URL: https://github.com/apache/kafka/pull/9084#issuecomment-709448776
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub a
[
https://issues.apache.org/jira/browse/KAFKA-10472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17214831#comment-17214831
]
Huynh Quang Thao commented on KAFKA-10472:
--
Ì Wiki you mentioned is Confluence,
[
https://issues.apache.org/jira/browse/KAFKA-10472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17214831#comment-17214831
]
Huynh Quang Thao edited comment on KAFKA-10472 at 10/15/20, 4:52 PM:
-
tombentley commented on pull request #9441:
URL: https://github.com/apache/kafka/pull/9441#issuecomment-709457342
I assumed the scheduler would be using a heap to prioritize scheduled tasks,
and that wouldn't preserve the order of submitted tasks with the same scheduled
time. Since `System
rajinisivaram commented on a change in pull request #9434:
URL: https://github.com/apache/kafka/pull/9434#discussion_r505698143
##
File path: core/src/main/scala/kafka/cluster/Partition.scala
##
@@ -1162,6 +1162,13 @@ class Partition(val topicPartition: TopicPartition,
loc
guozhangwang merged pull request #9438:
URL: https://github.com/apache/kafka/pull/9438
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
guozhangwang commented on pull request #9438:
URL: https://github.com/apache/kafka/pull/9438#issuecomment-709461497
Updated the unit tests and merged to trunk.
This is an automated message from the Apache Git Service.
To resp
guozhangwang commented on pull request #9438:
URL: https://github.com/apache/kafka/pull/9438#issuecomment-709462107
Cherry-picking to 2.7 as well since it has a reasonably large impact for any
old versioned clients. cc @bbejeck
[
https://issues.apache.org/jira/browse/KAFKA-10613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17214839#comment-17214839
]
Guozhang Wang commented on KAFKA-10613:
---
When we introduce the new version 4 in li
[
https://issues.apache.org/jira/browse/KAFKA-10613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-10613:
--
Component/s: (was: streams)
core
> Broker should not set leader epoch if
[
https://issues.apache.org/jira/browse/KAFKA-10613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-10613.
---
Fix Version/s: 2.7.0
Resolution: Fixed
> Broker should not set leader epoch if the li
[
https://issues.apache.org/jira/browse/KAFKA-10613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-10613:
--
Issue Type: Bug (was: Improvement)
> Broker should not set leader epoch if the list-offset re
[
https://issues.apache.org/jira/browse/KAFKA-10613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-10613:
--
Affects Version/s: 2.1.0
2.2.0
2.3.0
[
https://issues.apache.org/jira/browse/KAFKA-10613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17214839#comment-17214839
]
Guozhang Wang edited comment on KAFKA-10613 at 10/15/20, 5:07 PM:
guozhangwang merged pull request #9416:
URL: https://github.com/apache/kafka/pull/9416
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-8940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman reopened KAFKA-8940:
Assignee: (was: Guozhang Wang)
This failed again with
{code:java}
min fail: k
zhaohaidao commented on a change in pull request #9311:
URL: https://github.com/apache/kafka/pull/9311#discussion_r505707007
##
File path:
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java
##
@@ -1198,18 +1209,22 @@ boolean canBumpEpoch(
zhaohaidao commented on a change in pull request #9311:
URL: https://github.com/apache/kafka/pull/9311#discussion_r505708598
##
File path:
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java
##
@@ -1198,18 +1209,22 @@ boolean canBumpEpoch(
junrao merged pull request #9436:
URL: https://github.com/apache/kafka/pull/9436
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
rajinisivaram commented on a change in pull request #9434:
URL: https://github.com/apache/kafka/pull/9434#discussion_r505716802
##
File path: core/src/main/scala/kafka/cluster/Partition.scala
##
@@ -1162,6 +1162,13 @@ class Partition(val topicPartition: TopicPartition,
loc
rajinisivaram commented on a change in pull request #9434:
URL: https://github.com/apache/kafka/pull/9434#discussion_r505716961
##
File path: core/src/main/scala/kafka/server/FetchSession.scala
##
@@ -77,7 +77,8 @@ class CachedPartition(val topic: String,
rajinisivaram commented on pull request #9434:
URL: https://github.com/apache/kafka/pull/9434#issuecomment-709478153
@hachikuji Thanks for the review, have addressed the comments
This is an automated message from the Apache G
[
https://issues.apache.org/jira/browse/KAFKA-8531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17214863#comment-17214863
]
Gary Russell commented on KAFKA-8531:
-
[~mjsax] Will do; I just didn't think it worth
abbccdda commented on a change in pull request #9270:
URL: https://github.com/apache/kafka/pull/9270#discussion_r505721807
##
File path:
core/src/test/scala/unit/kafka/coordinator/group/GroupCoordinatorTest.scala
##
@@ -3789,6 +3844,41 @@ class GroupCoordinatorTest {
zhaohaidao commented on a change in pull request #9311:
URL: https://github.com/apache/kafka/pull/9311#discussion_r505722044
##
File path:
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java
##
@@ -1438,7 +1455,8 @@ public void handleRespo
zhaohaidao commented on a change in pull request #9311:
URL: https://github.com/apache/kafka/pull/9311#discussion_r505721580
##
File path: core/src/test/scala/unit/kafka/server/KafkaApisTest.scala
##
@@ -671,6 +782,57 @@ class KafkaApisTest {
}
}
+ @Test
+ def
shou
zhaohaidao commented on a change in pull request #9311:
URL: https://github.com/apache/kafka/pull/9311#discussion_r505722145
##
File path:
core/src/main/scala/kafka/coordinator/transaction/TransactionCoordinator.scala
##
@@ -381,9 +388,14 @@ class TransactionCoordinator(broker
cyrusv commented on pull request #8918:
URL: https://github.com/apache/kafka/pull/8918#issuecomment-709483443
@rhauch, thanks for the review, I've made the requested changes.
This is an automated message from the Apache Git S
garyrussell opened a new pull request #9444:
URL: https://github.com/apache/kafka/pull/9444
Doc fix for KAFKA-8305; mention its alternate use.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build s
[
https://issues.apache.org/jira/browse/KAFKA-10592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ron Dagostino reassigned KAFKA-10592:
-
Assignee: (was: Nikolay Izhikov)
> system tests not running after python3 merge
> -
[
https://issues.apache.org/jira/browse/KAFKA-10592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ron Dagostino reassigned KAFKA-10592:
-
Assignee: Manikumar
> system tests not running after python3 merge
> --
gquintana opened a new pull request #9445:
URL: https://github.com/apache/kafka/pull/9445
Improve broker logs when a client authenticates using Plain mechanism and
wrong password.
This helps identifying wihich client is misconfigured.
--
kkonstantine commented on pull request #9149:
URL: https://github.com/apache/kafka/pull/9149#issuecomment-709501599
The failure on JDK 15 is unrelated
This is an automated message from the Apache Git Service.
To respond to th
kkonstantine merged pull request #9149:
URL: https://github.com/apache/kafka/pull/9149
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-10340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantine Karantasis updated KAFKA-10340:
---
Fix Version/s: 2.6.1
2.7.0
> Source connectors should rep
[
https://issues.apache.org/jira/browse/KAFKA-10611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantine Karantasis resolved KAFKA-10611.
Resolution: Fixed
> Merge log error to avoid double error
> --
kkonstantine commented on pull request #9422:
URL: https://github.com/apache/kafka/pull/9422#issuecomment-709525339
The single failure in JDK 8 is unrelated.
This is an automated message from the Apache Git Service.
To respo
kkonstantine merged pull request #9422:
URL: https://github.com/apache/kafka/pull/9422
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-10602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantine Karantasis updated KAFKA-10602:
---
Fix Version/s: 2.6.1
2.7.0
> DLQ Reporter throws NPE when
[
https://issues.apache.org/jira/browse/KAFKA-10602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantine Karantasis resolved KAFKA-10602.
Resolution: Fixed
> DLQ Reporter throws NPE when reporting from different
hachikuji commented on a change in pull request #9103:
URL: https://github.com/apache/kafka/pull/9103#discussion_r505765664
##
File path: clients/src/main/java/org/apache/kafka/common/protocol/Errors.java
##
@@ -338,7 +339,9 @@
INCONSISTENT_VOTER_SET(94, "Indicates that th
[
https://issues.apache.org/jira/browse/KAFKA-10592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17214975#comment-17214975
]
Nikolay Izhikov commented on KAFKA-10592:
-
[~rndgstn] Why you unassign from me?
abbccdda commented on a change in pull request #9103:
URL: https://github.com/apache/kafka/pull/9103#discussion_r505842904
##
File path: clients/src/main/java/org/apache/kafka/common/protocol/Errors.java
##
@@ -338,7 +339,9 @@
INCONSISTENT_VOTER_SET(94, "Indicates that the
abbccdda commented on a change in pull request #9103:
URL: https://github.com/apache/kafka/pull/9103#discussion_r505852939
##
File path: clients/src/main/java/org/apache/kafka/common/protocol/ApiKeys.java
##
@@ -251,7 +253,8 @@ public Struct parseResponse(short version, ByteBuf
rhauch commented on pull request #9425:
URL: https://github.com/apache/kafka/pull/9425#issuecomment-709604738
@kkonstantine thanks for the suggestion. I rebased and added a commit with
more unit tests for `AbstractHerder.generateResult(...)`.
--
ableegoldman commented on pull request #9432:
URL: https://github.com/apache/kafka/pull/9432#issuecomment-709610635
LGTM
Looks like the Java 8 build may have stalled? The Java 11 & 15 builds both
passed a while ago
Th
mjsax merged pull request #9432:
URL: https://github.com/apache/kafka/pull/9432
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
mjsax commented on pull request #9432:
URL: https://github.com/apache/kafka/pull/9432#issuecomment-709619232
Thanks for the PR @vamossagar12!
No ideal to just remove the test instead of adjusting them, but we can do
this in a follow up PR. @ableegoldman told me she will take care of
[
https://issues.apache.org/jira/browse/KAFKA-10559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-10559:
Affects Version/s: 2.7.0
> Don't shutdown the entire app upon TimeoutException during inte
[
https://issues.apache.org/jira/browse/KAFKA-10559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-10559:
Labels: (was: pull-request-available)
> Don't shutdown the entire app upon TimeoutExcept
ableegoldman opened a new pull request #9446:
URL: https://github.com/apache/kafka/pull/9446
Minor followup to KAFKA-10559
I noticed that we were converting any and all TaskAssignmentException to the
INCOMPLETE_SOURCE_TOPIC_METADATA error code to shut down all the clients. Since
the
ableegoldman commented on a change in pull request #9446:
URL: https://github.com/apache/kafka/pull/9446#discussion_r505900644
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java
##
@@ -330,75 +331,61 @@ public GroupAs
ableegoldman commented on a change in pull request #9446:
URL: https://github.com/apache/kafka/pull/9446#discussion_r505901265
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java
##
@@ -434,7 +430,7 @@ private boolean
ableegoldman commented on a change in pull request #9446:
URL: https://github.com/apache/kafka/pull/9446#discussion_r505901990
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java
##
@@ -1235,7 +1232,7 @@ private boolea
ableegoldman commented on a change in pull request #9446:
URL: https://github.com/apache/kafka/pull/9446#discussion_r505901801
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java
##
@@ -704,8 +700,9 @@ private boolean
ableegoldman commented on pull request #9446:
URL: https://github.com/apache/kafka/pull/9446#issuecomment-709625902
heads up @mjsax @guozhangwang
This is an automated message from the Apache Git Service.
To respond to the me
mjsax commented on pull request #9432:
URL: https://github.com/apache/kafka/pull/9432#issuecomment-709635418
Follow up PR: https://github.com/apache/kafka/pull/9446
This is an automated message from the Apache Git Service.
To
mjsax merged pull request #9384:
URL: https://github.com/apache/kafka/pull/9384
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-10592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17215066#comment-17215066
]
Ron Dagostino commented on KAFKA-10592:
---
Hi [~nizhikov]. I believe the problem ma
mjsax commented on pull request #9368:
URL: https://github.com/apache/kafka/pull/9368#issuecomment-709641131
Updated.
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHu
1 - 100 of 117 matches
Mail list logo
