[jira] [Updated] (KAFKA-8343) streams application crashed due to rocksdb

[ https://issues.apache.org/jira/browse/KAFKA-8343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] gaoshu updated KAFKA-8343: -- Attachment: fullsizeoutput_6.jpeg > streams application crashed due to rocksdb > --

[jira] [Updated] (KAFKA-8343) streams application crashed due to rocksdb

[ https://issues.apache.org/jira/browse/KAFKA-8343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] gaoshu updated KAFKA-8343: -- Attachment: (was: fullsizeoutput_1.jpeg) > streams application crashed due to rocksdb > ---

[jira] [Created] (KAFKA-8343) streams application crashed due to rocksdb

gaoshu created KAFKA-8343: - Summary: streams application crashed due to rocksdb Key: KAFKA-8343 URL: https://issues.apache.org/jira/browse/KAFKA-8343 Project: Kafka Issue Type: Bug Componen

[jira] [Comment Edited] (KAFKA-8335) Log cleaner skips Transactional mark and batch record, causing unlimited growth of __consumer_offsets

[ https://issues.apache.org/jira/browse/KAFKA-8335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16836075#comment-16836075 ] Boquan Tang edited comment on KAFKA-8335 at 5/9/19 4:56 AM: H

[jira] [Commented] (KAFKA-8335) Log cleaner skips Transactional mark and batch record, causing unlimited growth of __consumer_offsets

[ https://issues.apache.org/jira/browse/KAFKA-8335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16836075#comment-16836075 ] Boquan Tang commented on KAFKA-8335: Hi [~hachikuji] thanks for replying. As Weichu

[jira] [Assigned] (KAFKA-8311) Better consumer timeout exception handling

[ https://issues.apache.org/jira/browse/KAFKA-8311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-8311: -- Assignee: (was: Boyang Chen) > Better consumer timeout exception handling > -

[jira] [Updated] (KAFKA-8335) Log cleaner skips Transactional mark and batch record, causing unlimited growth of __consumer_offsets

[ https://issues.apache.org/jira/browse/KAFKA-8335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boquan Tang updated KAFKA-8335: --- Attachment: seg_april_25.zip > Log cleaner skips Transactional mark and batch record, causing unlimit

[jira] [Updated] (KAFKA-8335) Log cleaner skips Transactional mark and batch record, causing unlimited growth of __consumer_offsets

[ https://issues.apache.org/jira/browse/KAFKA-8335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boquan Tang updated KAFKA-8335: --- Attachment: (was: seg_april_25.zip) > Log cleaner skips Transactional mark and batch record, caus

[jira] [Resolved] (KAFKA-8284) Enable static membership on KStream

[ https://issues.apache.org/jira/browse/KAFKA-8284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-8284. Resolution: Fixed > Enable static membership on KStream > --- > >

[jira] [Commented] (KAFKA-8311) Better consumer timeout exception handling

[ https://issues.apache.org/jira/browse/KAFKA-8311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16836068#comment-16836068 ] Boyang Chen commented on KAFKA-8311: [~clearpal7] Thanks for interest! You need to se

[jira] [Updated] (KAFKA-8335) Log cleaner skips Transactional mark and batch record, causing unlimited growth of __consumer_offsets

[ https://issues.apache.org/jira/browse/KAFKA-8335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boquan Tang updated KAFKA-8335: --- Attachment: seg_april_25.zip > Log cleaner skips Transactional mark and batch record, causing unlimit

[jira] [Commented] (KAFKA-8339) At-least-once delivery guarantee seemingly not met due to async commit / produce failure race condition

[ https://issues.apache.org/jira/browse/KAFKA-8339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16836065#comment-16836065 ] tdp commented on KAFKA-8339: Hi Matthias, Thanks for the quick reply! After digging into thi

[jira] [Commented] (KAFKA-7500) MirrorMaker 2.0 (KIP-382)

[ https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16836058#comment-16836058 ] Ryanne Dolan commented on KAFKA-7500: - [~cloudfrog], glad you are taking a look. I'm

[jira] [Commented] (KAFKA-8335) Log cleaner skips Transactional mark and batch record, causing unlimited growth of __consumer_offsets

[ https://issues.apache.org/jira/browse/KAFKA-8335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16836061#comment-16836061 ] Weichu Liu commented on KAFKA-8335: --- Hi, I uploaded a sample segment here: [^segment.zi

[jira] [Updated] (KAFKA-8335) Log cleaner skips Transactional mark and batch record, causing unlimited growth of __consumer_offsets

[ https://issues.apache.org/jira/browse/KAFKA-8335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weichu Liu updated KAFKA-8335: -- Attachment: segment.zip > Log cleaner skips Transactional mark and batch record, causing unlimited > g

[jira] [Commented] (KAFKA-7500) MirrorMaker 2.0 (KIP-382)

[ https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16836033#comment-16836033 ] Dan Casey commented on KAFKA-7500: -- I'm excited to test this as well.  We've been fighti

[jira] [Updated] (KAFKA-8342) Admin tool to setup Kafka Stream topology (internal) topics

[ https://issues.apache.org/jira/browse/KAFKA-8342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-8342: --- Labels: newbie (was: ) > Admin tool to setup Kafka Stream topology (internal) topics > -

[jira] [Updated] (KAFKA-8342) Admin tool to setup Kafka Stream topology (internal) topics

[ https://issues.apache.org/jira/browse/KAFKA-8342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-8342: --- Issue Type: New Feature (was: Bug) > Admin tool to setup Kafka Stream topology (internal) topics > -

[jira] [Commented] (KAFKA-8311) Better consumer timeout exception handling

[ https://issues.apache.org/jira/browse/KAFKA-8311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16836028#comment-16836028 ] WooYoung commented on KAFKA-8311: - Hello [~bchen225242]. I`m a new committer Kafka Projec

[jira] [Created] (KAFKA-8342) Admin tool to setup Kafka Stream topology (internal) topics

Boyang Chen created KAFKA-8342: -- Summary: Admin tool to setup Kafka Stream topology (internal) topics Key: KAFKA-8342 URL: https://issues.apache.org/jira/browse/KAFKA-8342 Project: Kafka Issue

[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] [Resolved] (KAFKA-7830) Convert Kafka RPCs to use automatically generated code

[ https://issues.apache.org/jira/browse/KAFKA-7830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-7830. Resolution: Fixed > Convert Kafka RPCs to use automatically generated code > --

[jira] [Reopened] (KAFKA-7830) Convert Kafka RPCs to use automatically generated code

[ https://issues.apache.org/jira/browse/KAFKA-7830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reopened KAFKA-7830: > Convert Kafka RPCs to use automatically generated code >

[jira] [Resolved] (KAFKA-8196) Replace InitProducerId request/response with automated protocol

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

[jira] [Commented] (KAFKA-8339) At-least-once delivery guarantee seemingly not met due to async commit / produce failure race condition

[ https://issues.apache.org/jira/browse/KAFKA-8339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16835931#comment-16835931 ] Matthias J. Sax commented on KAFKA-8339: {quote}The race condition occurs when th

[jira] [Created] (KAFKA-8341) AdminClient should retry coordinator lookup after NOT_COORDINATOR error

Jason Gustafson created KAFKA-8341: -- Summary: AdminClient should retry coordinator lookup after NOT_COORDINATOR error Key: KAFKA-8341 URL: https://issues.apache.org/jira/browse/KAFKA-8341 Project: Ka

[jira] [Assigned] (KAFKA-8337) Fix tests/setup.cfg to work with pytest 4.x

[ https://issues.apache.org/jira/browse/KAFKA-8337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kengo Seki reassigned KAFKA-8337: - Assignee: Kengo Seki > Fix tests/setup.cfg to work with pytest 4.x > ---

[jira] [Created] (KAFKA-8340) ServiceLoader fails when used from isolated plugin path directory

Chris Egerton created KAFKA-8340: Summary: ServiceLoader fails when used from isolated plugin path directory Key: KAFKA-8340 URL: https://issues.apache.org/jira/browse/KAFKA-8340 Project: Kafka

[jira] [Created] (KAFKA-8339) At-least-once delivery guarantee seemingly not met due to async commit / produce failure race condition

tdp created KAFKA-8339: -- Summary: At-least-once delivery guarantee seemingly not met due to async commit / produce failure race condition Key: KAFKA-8339 URL: https://issues.apache.org/jira/browse/KAFKA-8339 Pro

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=16835832#comment-16835832 ] John Roesler commented on KAFKA-8315: - Hi [~the4thamigo_uk], Sorry for leaving you ha

[jira] [Comment Edited] (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:comment-tabpanel&focusedCommentId=16835832#comment-16835832 ] John Roesler edited comment on KAFKA-8315 at 5/8/19 7:17 PM: -

[jira] [Resolved] (KAFKA-8051) remove KafkaMbean when network close

[ https://issues.apache.org/jira/browse/KAFKA-8051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-8051. Resolution: Duplicate > remove KafkaMbean when network close >

[jira] [Resolved] (KAFKA-8049) remove KafkaMbean when network close

[ https://issues.apache.org/jira/browse/KAFKA-8049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-8049. Resolution: Duplicate > remove KafkaMbean when network close >

[jira] [Resolved] (KAFKA-8050) remove KafkaMbean when network close

[ https://issues.apache.org/jira/browse/KAFKA-8050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-8050. Resolution: Duplicate > remove KafkaMbean when network close >

[jira] [Resolved] (KAFKA-8048) remove KafkaMbean when network close

[ https://issues.apache.org/jira/browse/KAFKA-8048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-8048. Resolution: Duplicate > remove KafkaMbean when network close >

[jira] [Created] (KAFKA-8338) Improve consumer offset expiration logic to take subscription into account

Gwen Shapira created KAFKA-8338: --- Summary: Improve consumer offset expiration logic to take subscription into account Key: KAFKA-8338 URL: https://issues.apache.org/jira/browse/KAFKA-8338 Project: Kafka

[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: _This ticket proposes adding new ListSerializer and ListDeserializer classes as

[jira] [Comment Edited] (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:comment-tabpanel&focusedCommentId=16835784#comment-16835784 ] Andrew edited comment on KAFKA-8315 at 5/8/19 5:54 PM: --- After a lot

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=16835784#comment-16835784 ] Andrew commented on KAFKA-8315: --- After a lot of investigation, we think this issue is down

[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] [Resolved] (KAFKA-7320) Provide ability to disable auto topic creation in KafkaConsumer

[ https://issues.apache.org/jira/browse/KAFKA-7320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7320. Resolution: Fixed Fix Version/s: 2.3.0 > Provide ability to disable auto topic creat

[jira] [Commented] (KAFKA-7320) Provide ability to disable auto topic creation in KafkaConsumer

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

[jira] [Commented] (KAFKA-8335) Log cleaner skips Transactional mark and batch record, causing unlimited growth of __consumer_offsets

[ https://issues.apache.org/jira/browse/KAFKA-8335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16835720#comment-16835720 ] Jason Gustafson commented on KAFKA-8335: Thanks for the report. Can you provide y

[jira] [Commented] (KAFKA-8337) Fix tests/setup.cfg to work with pytest 4.x

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

[jira] [Created] (KAFKA-8337) Fix tests/setup.cfg to work with pytest 4.x

Kengo Seki created KAFKA-8337: - Summary: Fix tests/setup.cfg to work with pytest 4.x Key: KAFKA-8337 URL: https://issues.apache.org/jira/browse/KAFKA-8337 Project: Kafka Issue Type: Bug

[jira] [Updated] (KAFKA-7847) KIP-421: Automatically resolve external configurations.

[ https://issues.apache.org/jira/browse/KAFKA-7847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram updated KAFKA-7847: -- Fix Version/s: 2.3.0 > KIP-421: Automatically resolve external configurations. > --

[jira] [Commented] (KAFKA-7757) Too many open files after java.io.IOException: Connection to n was disconnected before the response was read

[ https://issues.apache.org/jira/browse/KAFKA-7757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16835621#comment-16835621 ] arthur commented on KAFKA-7757: --- Hello, we are also facing the same issue running kafka 2.2

[jira] [Updated] (KAFKA-7757) Too many open files after java.io.IOException: Connection to n was disconnected before the response was read

[ https://issues.apache.org/jira/browse/KAFKA-7757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] arthur updated KAFKA-7757: -- Attachment: dump.txt > Too many open files after java.io.IOException: Connection to n was > disconnected befor

[jira] [Comment Edited] (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=16835601#comment-16835601 ] Viktor Somogyi-Vass edited comment on KAFKA-8195 at 5/8/19 1:30 PM: ---

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

[ https://issues.apache.org/jira/browse/KAFKA-8195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Viktor Somogyi-Vass updated KAFKA-8195: --- Affects Version/s: 2.3.0 > Unstable Producer After Send Failure in Transaction >

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

[ https://issues.apache.org/jira/browse/KAFKA-8195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Viktor Somogyi-Vass reassigned KAFKA-8195: -- Assignee: Viktor Somogyi-Vass > Unstable Producer After Send Failure in Transa

[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=16835601#comment-16835601 ] Viktor Somogyi-Vass commented on KAFKA-8195: Tried to reproduce the second fl

[jira] [Commented] (KAFKA-8106) Reducing the allocation and copying of ByteBuffer when logValidator do validation.

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

[jira] [Commented] (KAFKA-1774) REPL and Shell Client for Admin Message RQ/RP

[ https://issues.apache.org/jira/browse/KAFKA-1774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16835466#comment-16835466 ] Viktor Somogyi-Vass commented on KAFKA-1774: The POC is here: https://github.

[jira] [Created] (KAFKA-8336) Enable dynamic update of client-side SSL factory in brokers

Rajini Sivaram created KAFKA-8336: - Summary: Enable dynamic update of client-side SSL factory in brokers Key: KAFKA-8336 URL: https://issues.apache.org/jira/browse/KAFKA-8336 Project: Kafka

[jira] [Commented] (KAFKA-7817) Multiple Consumer Group Management with Regex

[ https://issues.apache.org/jira/browse/KAFKA-7817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16835410#comment-16835410 ] ASF GitHub Bot commented on KAFKA-7817: --- rootex- commented on pull request #6700: K

[jira] [Created] (KAFKA-8335) Log cleaner skips Transactional mark and batch record, causing unlimited growth of __consumer_offsets

Boquan Tang created KAFKA-8335: -- Summary: Log cleaner skips Transactional mark and batch record, causing unlimited growth of __consumer_offsets Key: KAFKA-8335 URL: https://issues.apache.org/jira/browse/KAFKA-8335

[jira] [Commented] (KAFKA-8317) ClassCastException using KTable.suppress()

[ https://issues.apache.org/jira/browse/KAFKA-8317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16835391#comment-16835391 ] Andrew commented on KAFKA-8317: --- Ok thanks for the reply. I will try this later. What surpr

[jira] [Commented] (KAFKA-8317) ClassCastException using KTable.suppress()

[ https://issues.apache.org/jira/browse/KAFKA-8317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16835390#comment-16835390 ] Andrew commented on KAFKA-8317: --- Ok thanks for the reply. I will try this later. What surpr

[jira] [Commented] (KAFKA-8106) Reducing the allocation and copying of ByteBuffer when logValidator do validation.

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