[jira] [Assigned] (KAFKA-5085) Add test for rebalance exceptions

[ https://issues.apache.org/jira/browse/KAFKA-5085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mariam John reassigned KAFKA-5085: -- Assignee: (was: Mariam John) > Add test for rebalance exceptions >

[jira] [Assigned] (KAFKA-4994) Fix findbugs warning about OffsetStorageWriter#currentFlushId

[ https://issues.apache.org/jira/browse/KAFKA-4994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mariam John reassigned KAFKA-4994: -- Assignee: (was: Mariam John) > Fix findbugs warning about OffsetStorageWriter#currentFlushI

[jira] [Resolved] (KAFKA-4370) CorruptRecordException when ProducerRecord constructed without key nor partition and send

[ https://issues.apache.org/jira/browse/KAFKA-4370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mariam John resolved KAFKA-4370. Resolution: Duplicate Fix Version/s: 1.0.0 This is already fixed in [https://github.com/apach

[jira] [Commented] (KAFKA-4370) CorruptRecordException when ProducerRecord constructed without key nor partition and send

[ https://issues.apache.org/jira/browse/KAFKA-4370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16333414#comment-16333414 ] Mariam John commented on KAFKA-4370: I just verified this and looks like the error mes

[jira] [Commented] (KAFKA-5697) StreamThread.close() need to interrupt the stream threads to break the loop

[ https://issues.apache.org/jira/browse/KAFKA-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16333410#comment-16333410 ] Mariam John commented on KAFKA-5697: @Guozhang Wang, sorry for the delay in responding

[jira] [Assigned] (KAFKA-5697) StreamThread.close() need to interrupt the stream threads to break the loop

[ https://issues.apache.org/jira/browse/KAFKA-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mariam John reassigned KAFKA-5697: -- Assignee: (was: Mariam John) > StreamThread.close() need to interrupt the stream threads to

[jira] [Resolved] (KAFKA-6366) StackOverflowError in kafka-coordinator-heartbeat-thread

[ https://issues.apache.org/jira/browse/KAFKA-6366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6366. Resolution: Fixed > StackOverflowError in kafka-coordinator-heartbeat-thread > -

[jira] [Commented] (KAFKA-2200) kafkaProducer.send() should not call callback.onCompletion()

[ https://issues.apache.org/jira/browse/KAFKA-2200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1622#comment-1622 ] Yu LIU commented on KAFKA-2200: --- Hello [~becket_qin], I'm new to Kafka. I just have a look

[jira] [Updated] (KAFKA-6424) QueryableStateIntegrationTest#queryOnRebalance should accept raw text

[ https://issues.apache.org/jira/browse/KAFKA-6424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-6424: -- Summary: QueryableStateIntegrationTest#queryOnRebalance should accept raw text (was: QueryableStateIntegrationT

[jira] [Commented] (KAFKA-6303) Potential lack of synchronization in NioEchoServer#AcceptorThread

[ https://issues.apache.org/jira/browse/KAFKA-6303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16333251#comment-16333251 ] Ted Yu commented on KAFKA-6303: --- lgtm > Potential lack of synchronization in NioEchoServer#

[jira] [Resolved] (KAFKA-5889) MetricsTest is flaky

[ https://issues.apache.org/jira/browse/KAFKA-5889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu resolved KAFKA-5889. --- Resolution: Cannot Reproduce > MetricsTest is flaky > > > Key: KAFKA-5889