[jira] [Created] (KAFKA-6402) KStream Ktable join integration test fails randomly

Narendra Kumar created KAFKA-6402: - Summary: KStream Ktable join integration test fails randomly Key: KAFKA-6402 URL: https://issues.apache.org/jira/browse/KAFKA-6402 Project: Kafka Issue Typ

[jira] [Resolved] (KAFKA-8380) We can not create a topic, immediately write to it and then read.

[ https://issues.apache.org/jira/browse/KAFKA-8380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Narendra Kumar resolved KAFKA-8380. --- Resolution: Not A Problem > We can not create a topic, immediately write to it and then read.

[jira] [Commented] (KAFKA-4676) Kafka consumers gets stuck for some partitions

[ https://issues.apache.org/jira/browse/KAFKA-4676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15871619#comment-15871619 ] Narendra Kumar commented on KAFKA-4676: --- We are also facing the same issue. [~onur

[jira] [Created] (KAFKA-5145) Remove task close() call from closeNonAssignedSuspendedTasks method

Narendra Kumar created KAFKA-5145: - Summary: Remove task close() call from closeNonAssignedSuspendedTasks method Key: KAFKA-5145 URL: https://issues.apache.org/jira/browse/KAFKA-5145 Project: Kafka

[jira] [Updated] (KAFKA-5145) Remove task close() call from closeNonAssignedSuspendedTasks method

[ https://issues.apache.org/jira/browse/KAFKA-5145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Narendra Kumar updated KAFKA-5145: -- Reviewer: Guozhang Wang > Remove task close() call from closeNonAssignedSuspendedTasks method >

[jira] [Created] (KAFKA-5167) streams task gets stuck after re-balance due to LockException

Narendra Kumar created KAFKA-5167: - Summary: streams task gets stuck after re-balance due to LockException Key: KAFKA-5167 URL: https://issues.apache.org/jira/browse/KAFKA-5167 Project: Kafka

[jira] [Updated] (KAFKA-5167) streams task gets stuck after re-balance due to LockException

[ https://issues.apache.org/jira/browse/KAFKA-5167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Narendra Kumar updated KAFKA-5167: -- Attachment: logs.txt Description: During rebalance processor node's close() method gets cal

[jira] [Updated] (KAFKA-5167) streams task gets stuck after re-balance due to LockException

[ https://issues.apache.org/jira/browse/KAFKA-5167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Narendra Kumar updated KAFKA-5167: -- Attachment: BugTest.java DebugTransformer.java > streams task gets stuck after r

[jira] [Commented] (KAFKA-5167) streams task gets stuck after re-balance due to LockException

[ https://issues.apache.org/jira/browse/KAFKA-5167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16000661#comment-16000661 ] Narendra Kumar commented on KAFKA-5167: --- Hi [~mjsax] We are still facing this issue

[jira] [Commented] (KAFKA-5167) streams task gets stuck after re-balance due to LockException

[ https://issues.apache.org/jira/browse/KAFKA-5167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16002105#comment-16002105 ] Narendra Kumar commented on KAFKA-5167: --- [~mjsax] swallowing the exception in close

[jira] [Updated] (KAFKA-5167) streams task gets stuck after re-balance due to LockException

[ https://issues.apache.org/jira/browse/KAFKA-5167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Narendra Kumar updated KAFKA-5167: -- Description: During rebalance processor node's close() method gets called two times once from S