[jira] [Commented] (KAFKA-10062) Add a method to retrieve the current timestamp as known by the Streams app

2020-11-15 Thread Rohit Deshpande (Jira)
[ 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

[GitHub] [kafka] iprithv commented on pull request #9204: KAFKA-6181 Examining log messages with {{--deep-iteration}} should show superset of fields

2020-11-15 Thread GitBox
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

[GitHub] [kafka] ramesh-muthusamy commented on pull request #9319: KAFKA-10413 Allow even distribution of lost/new tasks when more than one worker j…

2020-11-15 Thread GitBox
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

[jira] [Assigned] (KAFKA-10701) First line of detailed stats from consumer-perf-test.sh incorrect

2020-11-15 Thread Liju (Jira)
[ 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 >

[GitHub] [kafka] ramesh-muthusamy commented on a change in pull request #9319: KAFKA-10413 Allow even distribution of lost/new tasks when more than one worker j…

2020-11-15 Thread GitBox
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 @

[jira] [Commented] (KAFKA-10719) MirrorMaker2 fails to update its runtime configuration

2020-11-15 Thread Ning Zhang (Jira)
[ 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

[jira] [Comment Edited] (KAFKA-10704) Mirror maker with TLS at target

2020-11-15 Thread Ning Zhang (Jira)
[ 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: ---

[jira] [Commented] (KAFKA-10704) Mirror maker with TLS at target

2020-11-15 Thread Ning Zhang (Jira)
[ 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

[GitHub] [kafka] ijuma commented on pull request #7906: KAFKA-9383: Expose consumer group metadata

2020-11-15 Thread GitBox
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

[GitHub] [kafka] vamossagar12 commented on pull request #9508: KAFKA-10648: Add Prefix Scan support to State Stores

2020-11-15 Thread GitBox
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?

[GitHub] [kafka] vamossagar12 commented on a change in pull request #9539: KAFKA-10634: Adding LeaderId to Voters list in LeaderChangeMessage

2020-11-15 Thread GitBox
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

[GitHub] [kafka] ramesh-muthusamy commented on pull request #9319: KAFKA-10413 Allow even distribution of lost/new tasks when more than one worker j…

2020-11-15 Thread GitBox
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

[GitHub] [kafka] ramesh-muthusamy commented on pull request #9319: KAFKA-10413 Allow even distribution of lost/new tasks when more than one worker j…

2020-11-15 Thread GitBox
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

[GitHub] [kafka] kowshik edited a comment on pull request #9596: KAFKA-10723: Fix LogManager shutdown error handling

2020-11-15 Thread GitBox
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