[jira] [Updated] (KAFKA-9210) kafka stream loss data

[ https://issues.apache.org/jira/browse/KAFKA-9210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] panpan.liu updated KAFKA-9210: -- Description: kafka broker: 2.0.1 kafka stream client: 2.1.0 # two applications run at the same time

[jira] [Updated] (KAFKA-9210) kafka stream loss data

[ https://issues.apache.org/jira/browse/KAFKA-9210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] panpan.liu updated KAFKA-9210: -- Attachment: screenshot-1.png > kafka stream loss data > -- > > Key:

[jira] [Updated] (KAFKA-9210) kafka stream loss data

[ https://issues.apache.org/jira/browse/KAFKA-9210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] panpan.liu updated KAFKA-9210: -- Attachment: app.log > kafka stream loss data > -- > > Key: KAFKA-92

[jira] [Updated] (KAFKA-9210) kafka stream loss data

[ https://issues.apache.org/jira/browse/KAFKA-9210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] panpan.liu updated KAFKA-9210: -- Description: kafka broker: 2.0.1 kafka stream client: 2.1.0 # two applications run at the same time

[jira] [Created] (KAFKA-9210) kafka stream loss data

panpan.liu created KAFKA-9210: - Summary: kafka stream loss data Key: KAFKA-9210 URL: https://issues.apache.org/jira/browse/KAFKA-9210 Project: Kafka Issue Type: Bug Affects Versions: 2.0.1

[jira] [Commented] (KAFKA-9205) Add an option to enforce rack-aware partition reassignment

[ https://issues.apache.org/jira/browse/KAFKA-9205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16977155#comment-16977155 ] sats commented on KAFKA-9205: - [~vahid] can you please create the KIP (Sorry i am newbie not

[jira] [Commented] (KAFKA-7356) Add gradle task for dependency listing

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

[jira] [Assigned] (KAFKA-9157) logcleaner could generate empty segment files after cleaning

[ https://issues.apache.org/jira/browse/KAFKA-9157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx reassigned KAFKA-9157: - Assignee: huxihx > logcleaner could generate empty segment files after cleaning > --

[jira] [Created] (KAFKA-9209) Avoid sending unnecessary offset updates from consumer after KIP-211

Michael Bingham created KAFKA-9209: -- Summary: Avoid sending unnecessary offset updates from consumer after KIP-211 Key: KAFKA-9209 URL: https://issues.apache.org/jira/browse/KAFKA-9209 Project: Kafka

[jira] [Commented] (KAFKA-8981) Add bandwidth limits to DegradedNetworkFault

[ https://issues.apache.org/jira/browse/KAFKA-8981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16977051#comment-16977051 ] ASF GitHub Bot commented on KAFKA-8981: --- mumrah commented on pull request #7446: KA

[jira] [Commented] (KAFKA-9188) Flaky Test SslAdminClientIntegrationTest.testSynchronousAuthorizerAclUpdatesBlockRequestThreads

[ https://issues.apache.org/jira/browse/KAFKA-9188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16977025#comment-16977025 ] Matthias J. Sax commented on KAFKA-9188: [https://builds.apache.org/job/kafka-pr-

[jira] [Comment Edited] (KAFKA-9207) Replica Out of Sync as creating ReplicaFetcher thread failed with connection to leader

[ https://issues.apache.org/jira/browse/KAFKA-9207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16976957#comment-16976957 ] Xue Liu edited comment on KAFKA-9207 at 11/18/19 11:38 PM: --- We

[jira] [Resolved] (KAFKA-8571) Not complete delayed produce requests when processing StopReplicaRequest causing high produce latency for acks=all

[ https://issues.apache.org/jira/browse/KAFKA-8571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-8571. Resolution: Fixed > Not complete delayed produce requests when processing StopReplicaReques

[jira] [Resolved] (KAFKA-9198) StopReplica handler should complete pending purgatory operations

[ https://issues.apache.org/jira/browse/KAFKA-9198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9198. Fix Version/s: 2.4.0 Resolution: Fixed The PR has been merged. I meant to change the

[jira] [Reopened] (KAFKA-9198) StopReplica handler should complete pending purgatory operations

[ https://issues.apache.org/jira/browse/KAFKA-9198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reopened KAFKA-9198: > StopReplica handler should complete pending purgatory operations > --

[jira] [Commented] (KAFKA-8571) Not complete delayed produce requests when processing StopReplicaRequest causing high produce latency for acks=all

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

[jira] [Commented] (KAFKA-9198) StopReplica handler should complete pending purgatory operations

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

[jira] [Comment Edited] (KAFKA-9207) Replica Out of Sync as creating ReplicaFetcher thread failed with connection to leader

[ https://issues.apache.org/jira/browse/KAFKA-9207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16976957#comment-16976957 ] Xue Liu edited comment on KAFKA-9207 at 11/18/19 10:50 PM: --- We

[jira] [Updated] (KAFKA-9207) Replica Out of Sync as creating ReplicaFetcher thread failed with connection to leader

[ https://issues.apache.org/jira/browse/KAFKA-9207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xue Liu updated KAFKA-9207: --- Attachment: error-connection.jpg > Replica Out of Sync as creating ReplicaFetcher thread failed with connecti

[jira] [Commented] (KAFKA-9207) Replica Out of Sync as creating ReplicaFetcher thread failed with connection to leader

[ https://issues.apache.org/jira/browse/KAFKA-9207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16976957#comment-16976957 ] Xue Liu commented on KAFKA-9207: We have some further discovery:   When creating that t

[jira] [Updated] (KAFKA-9207) Replica Out of Sync as creating ReplicaFetcher thread failed with connection to leader

[ https://issues.apache.org/jira/browse/KAFKA-9207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xue Liu updated KAFKA-9207: --- Summary: Replica Out of Sync as creating ReplicaFetcher thread failed with connection to leader (was: Replic

[jira] [Commented] (KAFKA-9205) Add an option to enforce rack-aware partition reassignment

[ https://issues.apache.org/jira/browse/KAFKA-9205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16976895#comment-16976895 ] Vahid Hashemian commented on KAFKA-9205: This will still likely require a KIP sin

[jira] [Commented] (KAFKA-8843) Zookeeper migration tool support for TLS

[ https://issues.apache.org/jira/browse/KAFKA-8843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16976893#comment-16976893 ] Kelly Schoenhofen commented on KAFKA-8843: -- Question, does ZK 3.5.6 allow for SS

[jira] [Updated] (KAFKA-8326) Add Serde> support

[ https://issues.apache.org/jira/browse/KAFKA-8326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniyar Yeralin updated KAFKA-8326: --- Description: _This ticket proposes adding new {color:#4c9aff}ListSerializer{color} and {colo

[jira] [Updated] (KAFKA-8326) Add Serde> support

[ https://issues.apache.org/jira/browse/KAFKA-8326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniyar Yeralin updated KAFKA-8326: --- Summary: Add Serde> support (was: Add List Serde) > Add Serde> support > ---

[jira] [Updated] (KAFKA-9205) Add an option to enforce rack-aware partition reassignment

[ https://issues.apache.org/jira/browse/KAFKA-9205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian updated KAFKA-9205: --- Description: One regularly used healing operation on Kafka clusters is replica reassignments

[jira] [Commented] (KAFKA-9205) Add an option to enforce rack-aware partition reassignment

[ https://issues.apache.org/jira/browse/KAFKA-9205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16976888#comment-16976888 ] Vahid Hashemian commented on KAFKA-9205: Thanks [~sbellapu] for the pointer. KIP-

[jira] [Updated] (KAFKA-9205) Add an option to enforce rack-aware partition reassignment

[ https://issues.apache.org/jira/browse/KAFKA-9205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian updated KAFKA-9205: --- Labels: (was: needs-kip) > Add an option to enforce rack-aware partition reassignment > ---

[jira] [Commented] (KAFKA-9205) Add an option to enforce rack-aware partition reassignment

[ https://issues.apache.org/jira/browse/KAFKA-9205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16976855#comment-16976855 ] sats commented on KAFKA-9205: - [~vahid] do you have new KIP ? or this can be a extension to

[jira] [Commented] (KAFKA-9208) Flaky Test SslAdminClientIntegrationTest.testCreatePartitions

[ https://issues.apache.org/jira/browse/KAFKA-9208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16976843#comment-16976843 ] Sophie Blee-Goldman commented on KAFKA-9208: Results cleaned up already but I

[jira] [Updated] (KAFKA-9207) Replica Out of Sync as ReplicaFetcher thread is dead

[ https://issues.apache.org/jira/browse/KAFKA-9207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xue Liu updated KAFKA-9207: --- Description: We sometimes see a replica for a partition is out of sync. When the issue happens, it seems tha

[jira] [Created] (KAFKA-9208) Flaky Test SslAdminClientIntegrationTest.testCreatePartitions

Sophie Blee-Goldman created KAFKA-9208: -- Summary: Flaky Test SslAdminClientIntegrationTest.testCreatePartitions Key: KAFKA-9208 URL: https://issues.apache.org/jira/browse/KAFKA-9208 Project: Kafk

[jira] [Updated] (KAFKA-9207) Replica Out of Sync as ReplicaFetcher thread is dead

[ https://issues.apache.org/jira/browse/KAFKA-9207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xue Liu updated KAFKA-9207: --- Description: We sometimes see a replica for a partition is out of sync. When the issue happens, it seems tha

[jira] [Created] (KAFKA-9207) Replica Out of Sync as ReplicaFetcher thread is dead

Xue Liu created KAFKA-9207: -- Summary: Replica Out of Sync as ReplicaFetcher thread is dead Key: KAFKA-9207 URL: https://issues.apache.org/jira/browse/KAFKA-9207 Project: Kafka Issue Type: Bug

[jira] [Updated] (KAFKA-9207) Replica Out of Sync as ReplicaFetcher thread is dead

[ https://issues.apache.org/jira/browse/KAFKA-9207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xue Liu updated KAFKA-9207: --- Description: We sometimes see a replica for a partition is out of sync. When the issue happens, it seems tha

[jira] [Created] (KAFKA-9206) Consumer should handle `CORRUPT_MESSAGE` error code in fetch response

Jason Gustafson created KAFKA-9206: -- Summary: Consumer should handle `CORRUPT_MESSAGE` error code in fetch response Key: KAFKA-9206 URL: https://issues.apache.org/jira/browse/KAFKA-9206 Project: Kafk

[jira] [Commented] (KAFKA-9157) logcleaner could generate empty segment files after cleaning

[ https://issues.apache.org/jira/browse/KAFKA-9157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16976745#comment-16976745 ] sats commented on KAFKA-9157: - [~huxi_2b] sure please go head. > logcleaner could generate e

[jira] [Created] (KAFKA-9205) Add an option to enforce rack-aware partition reassignment

Vahid Hashemian created KAFKA-9205: -- Summary: Add an option to enforce rack-aware partition reassignment Key: KAFKA-9205 URL: https://issues.apache.org/jira/browse/KAFKA-9205 Project: Kafka

[jira] [Commented] (KAFKA-9203) kafka-client 2.3.1 fails to consume lz4 compressed topic in kafka 2.1.1

[ https://issues.apache.org/jira/browse/KAFKA-9203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16976701#comment-16976701 ] Ismael Juma commented on KAFKA-9203: We upgraded lz4-java from 1.5.0 to 1.6.0 in Kafk

[jira] [Commented] (KAFKA-9203) kafka-client 2.3.1 fails to consume lz4 compressed topic in kafka 2.1.1

[ https://issues.apache.org/jira/browse/KAFKA-9203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16976693#comment-16976693 ] Ismael Juma commented on KAFKA-9203: Thanks for the report. We have many tests and wo

[jira] [Commented] (KAFKA-9180) Broker won't start with empty log dir

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

[jira] [Commented] (KAFKA-9170) KafkaStreams constructor fails to read configuration from Properties object created with default values

[ https://issues.apache.org/jira/browse/KAFKA-9170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16976669#comment-16976669 ] Oleg Muravskiy commented on KAFKA-9170: --- OK, I will need some time to figure out th

[jira] [Commented] (KAFKA-9184) Redundant task creation after worker fails to join a specific group generation

[ https://issues.apache.org/jira/browse/KAFKA-9184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16976650#comment-16976650 ] Timur Rubeko commented on KAFKA-9184: - Please, let me know should you need additional

[jira] [Comment Edited] (KAFKA-9184) Redundant task creation after worker fails to join a specific group generation

[ https://issues.apache.org/jira/browse/KAFKA-9184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16976648#comment-16976648 ] Timur Rubeko edited comment on KAFKA-9184 at 11/18/19 3:54 PM:

[jira] [Comment Edited] (KAFKA-9184) Redundant task creation after worker fails to join a specific group generation

[ https://issues.apache.org/jira/browse/KAFKA-9184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16976648#comment-16976648 ] Timur Rubeko edited comment on KAFKA-9184 at 11/18/19 3:50 PM:

[jira] [Commented] (KAFKA-9184) Redundant task creation after worker fails to join a specific group generation

[ https://issues.apache.org/jira/browse/KAFKA-9184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16976648#comment-16976648 ] Timur Rubeko commented on KAFKA-9184: - Hello. SO question author here. Following is

[jira] [Updated] (KAFKA-9204) ReplaceField transformation fails when encountering tombstone event

[ https://issues.apache.org/jira/browse/KAFKA-9204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Georgios Kalogiros updated KAFKA-9204: -- Fix Version/s: (was: 2.3.0) > ReplaceField transformation fails when encountering t

[jira] [Updated] (KAFKA-9204) ReplaceField transformation fails when encountering tombstone event

[ https://issues.apache.org/jira/browse/KAFKA-9204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Georgios Kalogiros updated KAFKA-9204: -- Affects Version/s: 2.3.0 > ReplaceField transformation fails when encountering tombston

[jira] [Created] (KAFKA-9204) ReplaceField transformation fails when encountering tombstone event

Georgios Kalogiros created KAFKA-9204: - Summary: ReplaceField transformation fails when encountering tombstone event Key: KAFKA-9204 URL: https://issues.apache.org/jira/browse/KAFKA-9204 Project:

[jira] [Comment Edited] (KAFKA-9124) KIP-497: ISR changes should be propagated via Kafka protocol

[ https://issues.apache.org/jira/browse/KAFKA-9124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16976446#comment-16976446 ] Viktor Somogyi-Vass edited comment on KAFKA-9124 at 11/18/19 11:06 AM:

[jira] [Updated] (KAFKA-9125) GroupMetadataManager and TransactionStateManager should query the controller instead of zkClient

[ https://issues.apache.org/jira/browse/KAFKA-9125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Viktor Somogyi-Vass updated KAFKA-9125: --- Summary: GroupMetadataManager and TransactionStateManager should query the controller

[jira] [Updated] (KAFKA-9203) kafka-client 2.3.1 fails to consume lz4 compressed topic in kafka 2.1.1

[ https://issues.apache.org/jira/browse/KAFKA-9203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Watzke updated KAFKA-9203: Description: I run kafka cluster 2.1.1 when I upgraded a client app to use kafka-client 2.3.0 (or

[jira] [Commented] (KAFKA-9124) KIP-497: ISR changes should be propagated via Kafka protocol

[ https://issues.apache.org/jira/browse/KAFKA-9124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16976446#comment-16976446 ] Viktor Somogyi-Vass commented on KAFKA-9124: [~cmccabe] sure. Do you think we

[jira] [Created] (KAFKA-9203) kafka-client 2.3.1 fails to consume lz4 compressed topic in kafka 2.1.1

David Watzke created KAFKA-9203: --- Summary: kafka-client 2.3.1 fails to consume lz4 compressed topic in kafka 2.1.1 Key: KAFKA-9203 URL: https://issues.apache.org/jira/browse/KAFKA-9203 Project: Kafka

[jira] [Assigned] (KAFKA-9167) Implement a broker to controller request channel

[ https://issues.apache.org/jira/browse/KAFKA-9167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Viktor Somogyi-Vass reassigned KAFKA-9167: -- Assignee: Viktor Somogyi-Vass (was: Dhruvil Shah) > Implement a broker to con

[jira] [Commented] (KAFKA-9167) Implement a broker to controller request channel

[ https://issues.apache.org/jira/browse/KAFKA-9167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16976440#comment-16976440 ] Viktor Somogyi-Vass commented on KAFKA-9167: Ok, let's catch up about your id

[jira] [Assigned] (KAFKA-8958) Fix Kafka Streams JavaDocs with regard to used Serdes

[ https://issues.apache.org/jira/browse/KAFKA-8958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] bibin sebastian reassigned KAFKA-8958: -- Assignee: (was: bibin sebastian) > Fix Kafka Streams JavaDocs with regard to used