[jira] [Assigned] (KAFKA-9234) Consider using @Nullable and @Nonnull annotations

[ https://issues.apache.org/jira/browse/KAFKA-9234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manasvi Gupta reassigned KAFKA-9234: Assignee: Manasvi Gupta > Consider using @Nullable and @Nonnull annotations >

[jira] [Assigned] (KAFKA-9034) kafka-run-class.sh will fail if JAVA_HOME has space

[ https://issues.apache.org/jira/browse/KAFKA-9034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manasvi Gupta reassigned KAFKA-9034: Assignee: Manasvi Gupta > kafka-run-class.sh will fail if JAVA_HOME has space > --

[jira] [Created] (KAFKA-9286) Improve producer performance

YunlongLou created KAFKA-9286: - Summary: Improve producer performance Key: KAFKA-9286 URL: https://issues.apache.org/jira/browse/KAFKA-9286 Project: Kafka Issue Type: Improvement Compo

[jira] [Commented] (KAFKA-9275) Print assignment and IP address in the log message when consumer leaves/removed from the group

[ https://issues.apache.org/jira/browse/KAFKA-9275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16990430#comment-16990430 ] dengziming commented on KAFKA-9275: --- the GroupCoordinator keeps assignment using a Byte

[jira] [Commented] (KAFKA-9275) Print assignment and IP address in the log message when consumer leaves/removed from the group

[ https://issues.apache.org/jira/browse/KAFKA-9275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16990553#comment-16990553 ] John Roesler commented on KAFKA-9275: - Yeah, to be honest, I was a little concerned a

[jira] [Updated] (KAFKA-9232) Coordinator new member heartbeat completion does not work for JoinGroup v3

[ https://issues.apache.org/jira/browse/KAFKA-9232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-9232: --- Affects Version/s: 2.3.1 2.1.1 2.2.2 > Coordinator new

[jira] [Commented] (KAFKA-7870) Error sending fetch request (sessionId=1578860481, epoch=INITIAL) to node 2: java.io.IOException: Connection to 2 was disconnected before the response was read.

[ https://issues.apache.org/jira/browse/KAFKA-7870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16990592#comment-16990592 ] VinayKumar commented on KAFKA-7870: --- As mentioned by [~ayusman] in the above comment, i

[jira] [Commented] (KAFKA-7697) Possible deadlock in kafka.cluster.Partition

[ https://issues.apache.org/jira/browse/KAFKA-7697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16990593#comment-16990593 ] VinayKumar commented on KAFKA-7697: --- Does increasing num.network.threads help improve t

[jira] [Commented] (KAFKA-9275) Print assignment and IP address in the log message when consumer leaves/removed from the group

[ https://issues.apache.org/jira/browse/KAFKA-9275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16990642#comment-16990642 ] Boyang Chen commented on KAFKA-9275: I don't think adding this information in runtime

[jira] [Commented] (KAFKA-9275) Print assignment and IP address in the log message when consumer leaves/removed from the group

[ https://issues.apache.org/jira/browse/KAFKA-9275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16990666#comment-16990666 ] dengziming commented on KAFKA-9275: --- https://issues.apache.org/jira/browse/KAFKA-9275

[jira] [Comment Edited] (KAFKA-9275) Print assignment and IP address in the log message when consumer leaves/removed from the group

[ https://issues.apache.org/jira/browse/KAFKA-9275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16990666#comment-16990666 ] dengziming edited comment on KAFKA-9275 at 12/8/19 12:43 AM: -

[jira] [Commented] (KAFKA-9275) Print assignment and IP address in the log message when consumer leaves/removed from the group

[ https://issues.apache.org/jira/browse/KAFKA-9275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16990668#comment-16990668 ] dengziming commented on KAFKA-9275: --- [~bchen225242] , So we can add an Admin client  AP

[jira] [Commented] (KAFKA-9034) kafka-run-class.sh will fail if JAVA_HOME has space

[ https://issues.apache.org/jira/browse/KAFKA-9034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16990678#comment-16990678 ] John Roesler commented on KAFKA-9034: - Either way, it would be a best practice to quo

[jira] [Commented] (KAFKA-9234) Consider using @Nullable and @Nonnull annotations

[ https://issues.apache.org/jira/browse/KAFKA-9234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16990681#comment-16990681 ] John Roesler commented on KAFKA-9234: - Hi [~hmed06], The answer is yes, you can just

[jira] [Commented] (KAFKA-9285) Implement failed message topic to account for processing lag during failure

[ https://issues.apache.org/jira/browse/KAFKA-9285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16990705#comment-16990705 ] Richard Yu commented on KAFKA-9285: --- It looks like I didn't do my research. Looks like

[jira] [Issue Comment Deleted] (KAFKA-9285) Implement failed message topic to account for processing lag during failure

[ https://issues.apache.org/jira/browse/KAFKA-9285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Richard Yu updated KAFKA-9285: -- Comment: was deleted (was: It looks like I didn't do my research. Looks like this is already fixed by

[jira] [Resolved] (KAFKA-9285) Implement failed message topic to account for processing lag during failure

[ https://issues.apache.org/jira/browse/KAFKA-9285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Richard Yu resolved KAFKA-9285. --- Resolution: Fixed Already resolved by Kafka Connect. > Implement failed message topic to account for

[jira] [Commented] (KAFKA-9173) StreamsPartitionAssignor assigns partitions to only one worker

[ https://issues.apache.org/jira/browse/KAFKA-9173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16990707#comment-16990707 ] Matthias J. Sax commented on KAFKA-9173: Seems it's only documented it Confluent

[jira] [Commented] (KAFKA-9173) StreamsPartitionAssignor assigns partitions to only one worker

[ https://issues.apache.org/jira/browse/KAFKA-9173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16990708#comment-16990708 ] Matthias J. Sax commented on KAFKA-9173: [~ableegoldman] Can you help to port the

[jira] [Created] (KAFKA-9287) Transaction completion may block unnecessarily after abortable error

Jason Gustafson created KAFKA-9287: -- Summary: Transaction completion may block unnecessarily after abortable error Key: KAFKA-9287 URL: https://issues.apache.org/jira/browse/KAFKA-9287 Project: Kafka

[jira] [Commented] (KAFKA-9287) Transaction completion may block unnecessarily after abortable error

[ https://issues.apache.org/jira/browse/KAFKA-9287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16990764#comment-16990764 ] ASF GitHub Bot commented on KAFKA-9287: --- hachikuji commented on pull request #7799: