[jira] [Issue Comment Deleted] (KAFKA-7697) Possible deadlock in kafka.cluster.Partition

[ https://issues.apache.org/jira/browse/KAFKA-7697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] can_he updated KAFKA-7697: -- Comment: was deleted (was: [~rsivaram] I hit the same issue with 2.1.0 for one month, every time I must kill -

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

[ https://issues.apache.org/jira/browse/KAFKA-7697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yanrui updated KAFKA-7697: -- Attachment: 322.tdump > Possible deadlock in kafka.cluster.Partition >

[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=16833591#comment-16833591 ] yanrui commented on KAFKA-7697: --- use 2.1.1 kafka which deadlock happen a moment ago，I hav

[jira] [Updated] (KAFKA-7971) Producer in Streams environment

[ https://issues.apache.org/jira/browse/KAFKA-7971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7971: --- Labels: needs-kip (was: newbie) > Producer in Streams environment >

[jira] [Commented] (KAFKA-7971) Producer in Streams environment

[ https://issues.apache.org/jira/browse/KAFKA-7971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16833680#comment-16833680 ] Matthias J. Sax commented on KAFKA-7971: [~Alex Rong] I added you to the list on

[jira] [Updated] (KAFKA-8315) Cannot pass Materialized into a join operation - hence cant set retention period independent of grace

[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8315: --- Component/s: streams > Cannot pass Materialized into a join operation - hence cant set retent

[jira] [Commented] (KAFKA-7895) Ktable supress operator emitting more than one record for the same key per window

[ https://issues.apache.org/jira/browse/KAFKA-7895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16833708#comment-16833708 ] Kun Song commented on KAFKA-7895: - Hi [~vvcephei], [~mjsax], any progress on that? > Kta

[jira] [Commented] (KAFKA-7455) JmxTool cannot connect to an SSL-enabled JMX RMI port

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

[jira] [Resolved] (KAFKA-7455) JmxTool cannot connect to an SSL-enabled JMX RMI port

[ https://issues.apache.org/jira/browse/KAFKA-7455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-7455. -- Resolution: Fixed Fix Version/s: 2.3.0 > JmxTool cannot connect to an SSL-enabled JMX RMI port >

[jira] [Commented] (KAFKA-8319) Flaky Test KafkaStreamsTest.statefulTopologyShouldCreateStateDirectory

[ https://issues.apache.org/jira/browse/KAFKA-8319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16833811#comment-16833811 ] Kamal Chandraprakash commented on KAFKA-8319: - [~bbejeck] Could you please po

[jira] [Commented] (KAFKA-8199) ClassCastException when trying to groupBy after suppress

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

[jira] [Commented] (KAFKA-8240) Source.equals() can fail with NPE

[ https://issues.apache.org/jira/browse/KAFKA-8240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16833833#comment-16833833 ] ASF GitHub Bot commented on KAFKA-8240: --- mjsax commented on pull request #6685: KAF

[jira] [Created] (KAFKA-8325) Remove from the incomplete set failed. This should be impossible

Mattia Barbon created KAFKA-8325: Summary: Remove from the incomplete set failed. This should be impossible Key: KAFKA-8325 URL: https://issues.apache.org/jira/browse/KAFKA-8325 Project: Kafka

[jira] [Commented] (KAFKA-8289) KTable, Long> can't be suppressed

[ https://issues.apache.org/jira/browse/KAFKA-8289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16833875#comment-16833875 ] John Roesler commented on KAFKA-8289: - Just confirming this has now been merged to 2.

[jira] [Comment Edited] (KAFKA-8289) KTable, Long> can't be suppressed

[ https://issues.apache.org/jira/browse/KAFKA-8289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16833875#comment-16833875 ] John Roesler edited comment on KAFKA-8289 at 5/6/19 2:38 PM: -

[jira] [Commented] (KAFKA-7895) Ktable supress operator emitting more than one record for the same key per window

[ https://issues.apache.org/jira/browse/KAFKA-7895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16833880#comment-16833880 ] John Roesler commented on KAFKA-7895: - Hi [~songkun], The release process takes a li

[jira] [Updated] (KAFKA-8204) Streams may flush state stores in the incorrect order

[ https://issues.apache.org/jira/browse/KAFKA-8204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-8204: Issue Type: Bug (was: Improvement) > Streams may flush state stores in the incorrect order > -

[jira] [Commented] (KAFKA-8195) Unstable Producer After Send Failure in Transaction

[ https://issues.apache.org/jira/browse/KAFKA-8195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16833938#comment-16833938 ] Kelvin Yin commented on KAFKA-8195: --- We are a financial software development company. O

[jira] [Created] (KAFKA-8326) Add List Serde

Daniyar Yeralin created KAFKA-8326: -- Summary: Add List Serde Key: KAFKA-8326 URL: https://issues.apache.org/jira/browse/KAFKA-8326 Project: Kafka Issue Type: Improvement Components

[jira] [Commented] (KAFKA-7994) Improve Stream-Time for rebalances and restarts

[ https://issues.apache.org/jira/browse/KAFKA-7994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16833952#comment-16833952 ] Richard Yu commented on KAFKA-7994: --- Alright, so I posted a small patch which might hel

[jira] [Updated] (KAFKA-7994) Improve Stream-Time for rebalances and restarts

[ https://issues.apache.org/jira/browse/KAFKA-7994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Richard Yu updated KAFKA-7994: -- Attachment: possible-patch.diff > Improve Stream-Time for rebalances and restarts > ---

[jira] [Resolved] (KAFKA-8319) Flaky Test KafkaStreamsTest.statefulTopologyShouldCreateStateDirectory

[ https://issues.apache.org/jira/browse/KAFKA-8319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8319. Resolution: Cannot Reproduce > Flaky Test KafkaStreamsTest.statefulTopologyShouldCreateStateDirecto

[jira] [Commented] (KAFKA-8319) Flaky Test KafkaStreamsTest.statefulTopologyShouldCreateStateDirectory

[ https://issues.apache.org/jira/browse/KAFKA-8319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16834033#comment-16834033 ] Bill Bejeck commented on KAFKA-8319: Hi [~ckamal], I don't have it anymore, but I've

[jira] [Commented] (KAFKA-8326) Add List Serde

[ https://issues.apache.org/jira/browse/KAFKA-8326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16834053#comment-16834053 ] Daniyar Yeralin commented on KAFKA-8326: TODO: once implementation is finalized a

[jira] [Assigned] (KAFKA-8326) Add List Serde

[ https://issues.apache.org/jira/browse/KAFKA-8326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-8326: -- Assignee: Daniyar Yeralin > Add List Serde > - > > Key

[jira] [Updated] (KAFKA-8326) Add List Serde

[ https://issues.apache.org/jira/browse/KAFKA-8326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8326: --- Labels: kip (was: ) > Add List Serde > - > > Key: KAFKA-8326

[jira] [Commented] (KAFKA-8056) Replace FindCoordinator request/response with automated protocol

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

[jira] [Resolved] (KAFKA-8056) Replace FindCoordinator request/response with automated protocol

[ https://issues.apache.org/jira/browse/KAFKA-8056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-8056. Resolution: Fixed > Replace FindCoordinator request/response with automated protocol >

[jira] [Resolved] (KAFKA-8255) Replica fetcher thread exits with OffsetOutOfRangeException

[ https://issues.apache.org/jira/browse/KAFKA-8255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-8255. Resolution: Resolved I'm going to resolve this. We believe the root cause was KAFKA-8306, w

[jira] [Updated] (KAFKA-8286) KIP-460 Admin Leader Election RPC

[ https://issues.apache.org/jira/browse/KAFKA-8286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jose Armando Garcia Sancio updated KAFKA-8286: -- Description: Tracking issue for implementing KIP-460. Tasks: # [Done]

[jira] [Commented] (KAFKA-8286) KIP-460 Admin Leader Election RPC

[ https://issues.apache.org/jira/browse/KAFKA-8286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16834281#comment-16834281 ] Jose Armando Garcia Sancio commented on KAFKA-8286: --- PR: https://github

[jira] [Updated] (KAFKA-8326) Add List Serde

[ https://issues.apache.org/jira/browse/KAFKA-8326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniyar Yeralin updated KAFKA-8326: --- Description: I propose _adding new ListSerializer and ListDeserializer classes as well as su

[jira] [Comment Edited] (KAFKA-8326) Add List Serde

[ https://issues.apache.org/jira/browse/KAFKA-8326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16834053#comment-16834053 ] Daniyar Yeralin edited comment on KAFKA-8326 at 5/7/19 1:26 AM: ---

[jira] [Created] (KAFKA-8327) Connection to Node2 was disconnected

suseendramani created KAFKA-8327: Summary: Connection to Node2 was disconnected Key: KAFKA-8327 URL: https://issues.apache.org/jira/browse/KAFKA-8327 Project: Kafka Issue Type: New Feature

[jira] [Commented] (KAFKA-3955) Kafka log recovery doesn't truncate logs on non-monotonic offsets, leading to failed broker boot

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

[jira] [Created] (KAFKA-8328) Kafka smooth expansion

ChenLin created KAFKA-8328: -- Summary: Kafka smooth expansion Key: KAFKA-8328 URL: https://issues.apache.org/jira/browse/KAFKA-8328 Project: Kafka Issue Type: Improvement Components: client

[jira] [Updated] (KAFKA-8328) Kafka smooth expansion

[ https://issues.apache.org/jira/browse/KAFKA-8328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ChenLin updated KAFKA-8328: --- Description: When expanding the kafka cluster, the new follower will read the data from the earliest offset.

[jira] [Commented] (KAFKA-8328) Kafka smooth expansion

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

[jira] [Updated] (KAFKA-8328) Kafka smooth expansion

[ https://issues.apache.org/jira/browse/KAFKA-8328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ChenLin updated KAFKA-8328: --- Attachment: Kafka_smooth_expansion.patch > Kafka smooth expansion > -- > >