[
https://issues.apache.org/jira/browse/KAFKA-10062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232574#comment-17232574
]
Rohit Deshpande commented on KAFKA-10062:
-
[~mjsax] [~vvcephei] [~psmolinski] ca
iprithv commented on pull request #9204:
URL: https://github.com/apache/kafka/pull/9204#issuecomment-727772418
@chia7712 have removed the redundant space and have attached a screenshot.
Please do review and merge the same.
https://user-images.githubusercontent.com/48927540/99220741-3
ramesh-muthusamy commented on pull request #9319:
URL: https://github.com/apache/kafka/pull/9319#issuecomment-727754929
@kkonstantine thanks for the test case, I was able to validate that the
tasks are evenly distributed among the new worker as well for both connectors
and tasks. Please r
[
https://issues.apache.org/jira/browse/KAFKA-10701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Liju reassigned KAFKA-10701:
Assignee: Liju
> First line of detailed stats from consumer-perf-test.sh incorrect
>
ramesh-muthusamy commented on a change in pull request #9319:
URL: https://github.com/apache/kafka/pull/9319#discussion_r523906307
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeAssignor.java
##
@@ -260,7 +259,7 @
[
https://issues.apache.org/jira/browse/KAFKA-10719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232354#comment-17232354
]
Ning Zhang commented on KAFKA-10719:
The potential config inconsistence of MM2 may b
[
https://issues.apache.org/jira/browse/KAFKA-10704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232338#comment-17232338
]
Ning Zhang edited comment on KAFKA-10704 at 11/15/20, 4:34 PM:
---
[
https://issues.apache.org/jira/browse/KAFKA-10704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232338#comment-17232338
]
Ning Zhang commented on KAFKA-10704:
This PR [https://github.com/apache/kafka/pull/9
ijuma commented on pull request #7906:
URL: https://github.com/apache/kafka/pull/7906#issuecomment-727596694
Quick note for the future, let's please mention the relevant KIP when adding
public APIs like this one.
This is an
vamossagar12 commented on pull request #9508:
URL: https://github.com/apache/kafka/pull/9508#issuecomment-727588493
hi @cadonna , wanted to know did you get a chance to look at my comment on
the failing test case and the changes in general?
vamossagar12 commented on a change in pull request #9539:
URL: https://github.com/apache/kafka/pull/9539#discussion_r523773938
##
File path: raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java
##
@@ -317,6 +317,9 @@ private void appendLeaderChangeMessage(LeaderState s
ramesh-muthusamy commented on pull request #9319:
URL: https://github.com/apache/kafka/pull/9319#issuecomment-727573227
> @ramesh-muthusamy I can confirm seeing the behavior that @kkonstantine has
reported. This is with Spot instances and running multiple connectors for
topics with a large
ramesh-muthusamy commented on pull request #9319:
URL: https://github.com/apache/kafka/pull/9319#issuecomment-727573081
> After writing another test, I confirmed my impression after first reading
the code. So, this fix would help if all the lost workers joined after leaving
the group at ab
kowshik edited a comment on pull request #9596:
URL: https://github.com/apache/kafka/pull/9596#issuecomment-727523253
cc @dhruvilshah3 @junrao @hachikuji for review
This is an automated message from the Apache Git Service.
To
14 matches
Mail list logo