[jira] [Created] (KAFKA-9277) move all group state transition rules into their states

dengziming created KAFKA-9277: - Summary: move all group state transition rules into their states Key: KAFKA-9277 URL: https://issues.apache.org/jira/browse/KAFKA-9277 Project: Kafka Issue Type: I

[jira] [Assigned] (KAFKA-9212) Keep receiving FENCED_LEADER_EPOCH while sending ListOffsetRequest

[ https://issues.apache.org/jira/browse/KAFKA-9212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reassigned KAFKA-9212: -- Assignee: Jason Gustafson > Keep receiving FENCED_LEADER_EPOCH while sending ListOffse

[jira] [Issue Comment Deleted] (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:all-tabpanel ] dengziming updated KAFKA-9275: -- Comment: was deleted (was: hi, we can print consumer information in rebalance logs, but I think it is

[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=16989443#comment-16989443 ] dengziming commented on KAFKA-9275: --- hi, we can print consumer information in rebalance

[jira] [Comment Edited] (KAFKA-9270) KafkaStream crash on offset commit failure

[ https://issues.apache.org/jira/browse/KAFKA-9270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16989410#comment-16989410 ] Rohan Kulkarni edited comment on KAFKA-9270 at 12/6/19 5:41 AM: ---

[jira] [Commented] (KAFKA-9270) KafkaStream crash on offset commit failure

[ https://issues.apache.org/jira/browse/KAFKA-9270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16989410#comment-16989410 ] Rohan Kulkarni commented on KAFKA-9270: --- Thanks [~vvcephei]. Appreciate your help o

[jira] [Commented] (KAFKA-9270) KafkaStream crash on offset commit failure

[ https://issues.apache.org/jira/browse/KAFKA-9270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16989401#comment-16989401 ] John Roesler commented on KAFKA-9270: - Hey Rohan, I see where you’re coming from, bu

[jira] [Commented] (KAFKA-9270) KafkaStream crash on offset commit failure

[ https://issues.apache.org/jira/browse/KAFKA-9270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16989396#comment-16989396 ] Rohan Kulkarni commented on KAFKA-9270: --- [~vvcephei], [~bchen225242] - Thanks for y

[jira] [Commented] (KAFKA-9270) KafkaStream crash on offset commit failure

[ https://issues.apache.org/jira/browse/KAFKA-9270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16989395#comment-16989395 ] Rohan Kulkarni commented on KAFKA-9270: --- [~vvcephei], [~bchen225242] - Thanks for y

[jira] [Updated] (KAFKA-9211) kafka upgrade 2.3.0 may cause tcp delay ack(Congestion Control)

[ https://issues.apache.org/jira/browse/KAFKA-9211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] li xiangyuan updated KAFKA-9211: Summary: kafka upgrade 2.3.0 may cause tcp delay ack(Congestion Control) (was: kafka upgrade 2.3.0

[jira] [Commented] (KAFKA-9211) kafka upgrade 2.3.0 cause produce speed decrease

[ https://issues.apache.org/jira/browse/KAFKA-9211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16989369#comment-16989369 ] li xiangyuan commented on KAFKA-9211: - After some test, I believe we have successfull

[jira] [Updated] (KAFKA-9211) kafka upgrade 2.3.0 cause produce speed decrease

[ https://issues.apache.org/jira/browse/KAFKA-9211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] li xiangyuan updated KAFKA-9211: Attachment: nodelay.txt > kafka upgrade 2.3.0 cause produce speed decrease > --

[jira] [Updated] (KAFKA-9211) kafka upgrade 2.3.0 cause produce speed decrease

[ https://issues.apache.org/jira/browse/KAFKA-9211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] li xiangyuan updated KAFKA-9211: Attachment: ackdelay.txt > kafka upgrade 2.3.0 cause produce speed decrease > -

[jira] [Updated] (KAFKA-9211) kafka upgrade 2.3.0 cause produce speed decrease

[ https://issues.apache.org/jira/browse/KAFKA-9211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] li xiangyuan updated KAFKA-9211: Attachment: producer.node.latency.png > kafka upgrade 2.3.0 cause produce speed decrease >

[jira] [Commented] (KAFKA-9212) Keep receiving FENCED_LEADER_EPOCH while sending ListOffsetRequest

[ https://issues.apache.org/jira/browse/KAFKA-9212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16989287#comment-16989287 ] Michael Jaschob commented on KAFKA-9212: Chiming in here, I believe we've experie

[jira] [Updated] (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:all-tabpanel ] Badai Aqrandista updated KAFKA-9275: Description: In order to simplify identification of which member is causing rebalance, can

[jira] [Created] (KAFKA-9276) Unclear warning due to empty throttled fetch response

Bob Barrett created KAFKA-9276: -- Summary: Unclear warning due to empty throttled fetch response Key: KAFKA-9276 URL: https://issues.apache.org/jira/browse/KAFKA-9276 Project: Kafka Issue Type: B

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

Badai Aqrandista created KAFKA-9275: --- Summary: Print assignment and IP address in the log message when consumer leaves/removed from the group Key: KAFKA-9275 URL: https://issues.apache.org/jira/browse/KAFKA-9275

[jira] [Updated] (KAFKA-9148) Consider forking RocksDB for Streams

[ https://issues.apache.org/jira/browse/KAFKA-9148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9148: --- Description: We recently upgraded our RocksDB dependency to 5.18 for its memory-manag

[jira] [Updated] (KAFKA-9148) Consider forking RocksDB for Streams

[ https://issues.apache.org/jira/browse/KAFKA-9148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9148: --- Description: We recently upgraded our RocksDB dependency to 5.18 for its memory-manag

[jira] [Commented] (KAFKA-9225) kafka fail to run on linux-aarch64

[ https://issues.apache.org/jira/browse/KAFKA-9225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16989225#comment-16989225 ] John Roesler commented on KAFKA-9225: - I see what you did there :) Forking RocksDB i

[jira] [Commented] (KAFKA-9260) Improve Serde "push down" and "wrapping"

[ https://issues.apache.org/jira/browse/KAFKA-9260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16989216#comment-16989216 ] Guozhang Wang commented on KAFKA-9260: -- One cause of the current design is that we u

[jira] [Commented] (KAFKA-9013) Flaky Test MirrorConnectorsIntegrationTest#testReplication

[ https://issues.apache.org/jira/browse/KAFKA-9013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16989207#comment-16989207 ] Guozhang Wang commented on KAFKA-9013: -- Happens again: https://builds.apache.org/jo

[jira] [Commented] (KAFKA-9225) kafka fail to run on linux-aarch64

[ https://issues.apache.org/jira/browse/KAFKA-9225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16989206#comment-16989206 ] Sophie Blee-Goldman commented on KAFKA-9225: At that point we might as well j

[jira] [Commented] (KAFKA-9225) kafka fail to run on linux-aarch64

[ https://issues.apache.org/jira/browse/KAFKA-9225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16989201#comment-16989201 ] John Roesler commented on KAFKA-9225: - Hey [~guozhang], Yes, I think it would be ok

[jira] [Comment Edited] (KAFKA-9274) Gracefully handle timeout exceptions on Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-9274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16989195#comment-16989195 ] John Roesler edited comment on KAFKA-9274 at 12/5/19 9:47 PM: -

[jira] [Commented] (KAFKA-9274) Gracefully handle timeout exceptions on Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-9274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16989195#comment-16989195 ] John Roesler commented on KAFKA-9274: - Thanks for starting this, [~bchen225242]! One

[jira] [Updated] (KAFKA-9073) Kafka Streams State stuck in rebalancing after one of the StreamThread encounters java.lang.IllegalStateException: No current assignment for partition

[ https://issues.apache.org/jira/browse/KAFKA-9073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-9073: - Fix Version/s: 2.3.2 > Kafka Streams State stuck in rebalancing after one of the StreamThread >

[jira] [Updated] (KAFKA-6989) Support Async Processing in Streams

[ https://issues.apache.org/jira/browse/KAFKA-6989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-6989: - Labels: api needs-kip (was: needs-kip) > Support Async Processing in Streams > -

[jira] [Commented] (KAFKA-9274) Gracefully handle timeout exceptions on Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-9274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16989190#comment-16989190 ] Bill Bejeck commented on KAFKA-9274: At the risk of stating the obvious,I think we sh

[jira] [Commented] (KAFKA-9225) kafka fail to run on linux-aarch64

[ https://issues.apache.org/jira/browse/KAFKA-9225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16989187#comment-16989187 ] Guozhang Wang commented on KAFKA-9225: -- [~vvcephei] Can we just require users to mak

[jira] [Created] (KAFKA-9274) Gracefully handle timeout exceptions on Kafka Streams

Boyang Chen created KAFKA-9274: -- Summary: Gracefully handle timeout exceptions on Kafka Streams Key: KAFKA-9274 URL: https://issues.apache.org/jira/browse/KAFKA-9274 Project: Kafka Issue Type: I

[jira] [Commented] (KAFKA-9131) failed producer metadata updates result in the unrelated error message

[ https://issues.apache.org/jira/browse/KAFKA-9131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16989161#comment-16989161 ] Guozhang Wang commented on KAFKA-9131: -- [~gkomissarov] Thanks for reporting and fixi

[jira] [Commented] (KAFKA-9131) failed producer metadata updates result in the unrelated error message

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

[jira] [Commented] (KAFKA-9270) KafkaStream crash on offset commit failure

[ https://issues.apache.org/jira/browse/KAFKA-9270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16989123#comment-16989123 ] John Roesler commented on KAFKA-9270: - Agreed, [~bchen225242], and I'm actually on bo

[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=16989070#comment-16989070 ] Sophie Blee-Goldman commented on KAFKA-9173: That's a good point, it does nee

[jira] [Commented] (KAFKA-9270) KafkaStream crash on offset commit failure

[ https://issues.apache.org/jira/browse/KAFKA-9270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16988991#comment-16988991 ] Boyang Chen commented on KAFKA-9270: [~vvcephei] In fact timeout exceptions is very c

[jira] [Commented] (KAFKA-9268) Follow-on: Streams Threads may die from recoverable errors with EOS enabled

[ https://issues.apache.org/jira/browse/KAFKA-9268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16988953#comment-16988953 ] John Roesler commented on KAFKA-9268: - The only compatibility concern I'm aware of is

[jira] [Created] (KAFKA-9273) Refactor AbstractJoinIntegrationTest and Sub-classes

Bill Bejeck created KAFKA-9273: -- Summary: Refactor AbstractJoinIntegrationTest and Sub-classes Key: KAFKA-9273 URL: https://issues.apache.org/jira/browse/KAFKA-9273 Project: Kafka Issue Type: Te

[jira] [Commented] (KAFKA-9270) KafkaStream crash on offset commit failure

[ https://issues.apache.org/jira/browse/KAFKA-9270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16988923#comment-16988923 ] John Roesler commented on KAFKA-9270: - Hey Rohan, There is a Consumer config to cont

[jira] [Commented] (KAFKA-9088) Consolidate InternalMockProcessorContext and MockInternalProcessorContext

[ https://issues.apache.org/jira/browse/KAFKA-9088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16988913#comment-16988913 ] John Roesler commented on KAFKA-9088: - Thanks, Bruno, I don’t want you to feel besieg

[jira] [Reopened] (KAFKA-9261) NPE when updating client metadata

[ https://issues.apache.org/jira/browse/KAFKA-9261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar reopened KAFKA-9261: -- > NPE when updating client metadata > - > > Key: KAFKA-9261

[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=16988777#comment-16988777 ] Oleg Muravskiy commented on KAFKA-9173: --- I understand that this is how it is *imple

[jira] [Commented] (KAFKA-9250) Kafka streams stuck in rebalancing state after UnknownHostException

[ https://issues.apache.org/jira/browse/KAFKA-9250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16988732#comment-16988732 ] Vijay commented on KAFKA-9250: -- Thanks [~guozhang], we are planning to update kafka clients

[jira] [Commented] (KAFKA-7447) Consumer offsets lost during leadership rebalance after bringing node back from clean shutdown

[ https://issues.apache.org/jira/browse/KAFKA-7447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16988699#comment-16988699 ] Karolis Pocius commented on KAFKA-7447: --- We've encountered the issue not after a cl

[jira] [Commented] (KAFKA-7447) Consumer offsets lost during leadership rebalance after bringing node back from clean shutdown

[ https://issues.apache.org/jira/browse/KAFKA-7447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16988680#comment-16988680 ] Francisco Juan commented on KAFKA-7447: --- Thanks [~Karolis]. Would it be possible f

[jira] [Created] (KAFKA-9272) Error when trying to connect to SSL port using PLAINTEXT is very confusing

Richard Wise created KAFKA-9272: --- Summary: Error when trying to connect to SSL port using PLAINTEXT is very confusing Key: KAFKA-9272 URL: https://issues.apache.org/jira/browse/KAFKA-9272 Project: Kafka

[jira] [Created] (KAFKA-9271) Client hangs until timeout when SSL handshake fails

Richard Wise created KAFKA-9271: --- Summary: Client hangs until timeout when SSL handshake fails Key: KAFKA-9271 URL: https://issues.apache.org/jira/browse/KAFKA-9271 Project: Kafka Issue Type: B

[jira] [Commented] (KAFKA-8896) NoSuchElementException after coordinator move

[ https://issues.apache.org/jira/browse/KAFKA-8896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16988654#comment-16988654 ] Francisco Juan commented on KAFKA-8896: --- Hello [~hachikuji], could you please provi

[jira] [Commented] (KAFKA-9219) NullPointerException when polling metrics from Kafka Connect

[ https://issues.apache.org/jira/browse/KAFKA-9219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16988631#comment-16988631 ] Mickael Maison commented on KAFKA-9219: --- Great! I wanted to backport it to 2.4 but

[jira] [Commented] (KAFKA-7447) Consumer offsets lost during leadership rebalance after bringing node back from clean shutdown

[ https://issues.apache.org/jira/browse/KAFKA-7447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16988629#comment-16988629 ] Karolis Pocius commented on KAFKA-7447: --- [~francisco.juan], we went straight for 2.

[jira] [Commented] (KAFKA-7447) Consumer offsets lost during leadership rebalance after bringing node back from clean shutdown

[ https://issues.apache.org/jira/browse/KAFKA-7447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16988623#comment-16988623 ] Francisco Juan commented on KAFKA-7447: --- [~timvanlaer] we are seeing the same error

[jira] [Commented] (KAFKA-9088) Consolidate InternalMockProcessorContext and MockInternalProcessorContext

[ https://issues.apache.org/jira/browse/KAFKA-9088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16988579#comment-16988579 ] Bruno Cadonna commented on KAFKA-9088: -- I understand all your concerns and sometimes