[jira] [Created] (KAFKA-8576) Consumer failed to join the coordinator

2019-06-20 Thread yanrui (JIRA)
yanrui created KAFKA-8576: - Summary: Consumer failed to join the coordinator Key: KAFKA-8576 URL: https://issues.apache.org/jira/browse/KAFKA-8576 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-8574) EOS race condition during task transition leads to LocalStateStore truncation in Kafka Streams 2.0.1

2019-06-20 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16869051#comment-16869051 ] Matthias J. Sax commented on KAFKA-8574: Is this the same as 

[jira] [Updated] (KAFKA-8575) Investigate cleaning up task suspension (part 7)

2019-06-20 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8575: --- Component/s: streams > Investigate cleaning up task suspension (part 7) >

[jira] [Updated] (KAFKA-8452) Possible Suppress buffer optimization: de-duplicate prior value

2019-06-20 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8452: --- Fix Version/s: (was: 3.0.0) > Possible Suppress buffer optimization: de-duplicate prior

[jira] [Created] (KAFKA-8575) Investigate cleaning up task suspension

2019-06-20 Thread Sophie Blee-Goldman (JIRA)
Sophie Blee-Goldman created KAFKA-8575: -- Summary: Investigate cleaning up task suspension Key: KAFKA-8575 URL: https://issues.apache.org/jira/browse/KAFKA-8575 Project: Kafka Issue

[jira] [Updated] (KAFKA-8575) Investigate cleaning up task suspension (part 7)

2019-06-20 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8575: --- Summary: Investigate cleaning up task suspension (part 7) (was: Investigate

[jira] [Updated] (KAFKA-8574) EOS race condition during task transition leads to LocalStateStore truncation in Kafka Streams 2.0.1

2019-06-20 Thread William Greer (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] William Greer updated KAFKA-8574: - Description: *Overview* While using EOS in Kafka Stream there is a race condition where the

[jira] [Created] (KAFKA-8574) EOS race condition during task transition leads to LocalStateStore truncation in Kafka Streams 2.0.1

2019-06-20 Thread William Greer (JIRA)
William Greer created KAFKA-8574: Summary: EOS race condition during task transition leads to LocalStateStore truncation in Kafka Streams 2.0.1 Key: KAFKA-8574 URL:

[jira] [Commented] (KAFKA-8392) Kafka broker leaks metric when partition leader moves to another node.

2019-06-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16868946#comment-16868946 ] ASF GitHub Bot commented on KAFKA-8392: --- tuvtran commented on pull request #6977: KAFKA-8392: Fix

[jira] [Assigned] (KAFKA-8494) Refactor Consumer#StickyAssignor and add CooperativeStickyAssignor (part 4)

2019-06-20 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reassigned KAFKA-8494: -- Assignee: Sophie Blee-Goldman > Refactor Consumer#StickyAssignor and add

[jira] [Assigned] (KAFKA-8510) Update StreamsPartitionAssignor to use the built-in owned partitions to achieve stickiness (part 7)

2019-06-20 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reassigned KAFKA-8510: -- Assignee: Sophie Blee-Goldman > Update StreamsPartitionAssignor to use the

[jira] [Commented] (KAFKA-8569) Integrate the poll timeout warning with leave group call

2019-06-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16868932#comment-16868932 ] ASF GitHub Bot commented on KAFKA-8569: --- guozhangwang commented on pull request #6972: KAFKA-8569:

[jira] [Commented] (KAFKA-8527) add dynamic maintenance broker config

2019-06-20 Thread GEORGE LI (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16868914#comment-16868914 ] GEORGE LI commented on KAFKA-8527: -- We had this implemented in a separate admin service outside of

[jira] [Assigned] (KAFKA-8546) Call System#runFinalization to avoid memory leak caused by JDK-6293787

2019-06-20 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee Dongjin reassigned KAFKA-8546: -- Assignee: Lee Dongjin > Call System#runFinalization to avoid memory leak caused by

[jira] [Commented] (KAFKA-8546) Call System#runFinalization to avoid memory leak caused by JDK-6293787

2019-06-20 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16868844#comment-16868844 ] Lee Dongjin commented on KAFKA-8546: Hi [~badai], Here is the patch: [^KAFKA-8546.patch] I confirmed

[jira] [Updated] (KAFKA-8546) Call System#runFinalization to avoid memory leak caused by JDK-6293787

2019-06-20 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee Dongjin updated KAFKA-8546: --- Attachment: KAFKA-8546.patch > Call System#runFinalization to avoid memory leak caused by

[jira] [Commented] (KAFKA-8546) Call System#runFinalization to avoid memory leak caused by JDK-6293787

2019-06-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16868842#comment-16868842 ] ASF GitHub Bot commented on KAFKA-8546: --- dongjinleekr commented on pull request #6976: KAFKA-8546:

[jira] [Comment Edited] (KAFKA-7368) Support joining Windowed KTables

2019-06-20 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16867770#comment-16867770 ] John Roesler edited comment on KAFKA-7368 at 6/20/19 5:23 PM: -- Also, note

[jira] [Updated] (KAFKA-8452) Possible Suppress buffer optimization: de-duplicate prior value

2019-06-20 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-8452: Fix Version/s: 2.4.0 3.0.0 > Possible Suppress buffer optimization:

[jira] [Resolved] (KAFKA-8452) Possible Suppress buffer optimization: de-duplicate prior value

2019-06-20 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-8452. - Resolution: Fixed > Possible Suppress buffer optimization: de-duplicate prior value >

[jira] [Commented] (KAFKA-8405) Remove deprecated preferred leader RPC and Command

2019-06-20 Thread Jose Armando Garcia Sancio (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16868669#comment-16868669 ] Jose Armando Garcia Sancio commented on KAFKA-8405: --- [~m.sandeep] thanks for working on

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

2019-06-20 Thread Francisco Juan (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16868545#comment-16868545 ] Francisco Juan commented on KAFKA-8335: --- Hi Boquan Cleaning up the {{cleaner-offset-checkpoint}}

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

2019-06-20 Thread Adam Bellemare (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16868544#comment-16868544 ] Adam Bellemare commented on KAFKA-7500: --- [~ryannedolan] - Thanks for driving this forward, it looks

[jira] [Commented] (KAFKA-8405) Remove deprecated preferred leader RPC and Command

2019-06-20 Thread Sandeep (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16868542#comment-16868542 ] Sandeep commented on KAFKA-8405: [~jagsancio] I have already completed the changes. Can I still go ahead

[jira] [Updated] (KAFKA-8573) kafka-topics.cmd OOM when connecting to a secure cluster without SSL properties

2019-06-20 Thread Jorg Heymans (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jorg Heymans updated KAFKA-8573: Environment: Windows 7 openjdk version "1.8.0_212-1-ojdkbuild" OpenJDK Runtime Environment (build

[jira] [Created] (KAFKA-8573) kafka-topics.cmd OOM when connecting to a secure cluster without SSL properties

2019-06-20 Thread Jorg Heymans (JIRA)
Jorg Heymans created KAFKA-8573: --- Summary: kafka-topics.cmd OOM when connecting to a secure cluster without SSL properties Key: KAFKA-8573 URL: https://issues.apache.org/jira/browse/KAFKA-8573 Project:

[jira] [Commented] (KAFKA-560) Garbage Collect obsolete topics

2019-06-20 Thread Carlos Manuel Duclos Vergara (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16868489#comment-16868489 ] Carlos Manuel Duclos Vergara commented on KAFKA-560: I guess nothing has happened

[jira] [Commented] (KAFKA-7995) Augment singleton protocol type to list for Kafka Consumer

2019-06-20 Thread Carlos Manuel Duclos Vergara (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16868476#comment-16868476 ] Carlos Manuel Duclos Vergara commented on KAFKA-7995: - Do you need help on this? >

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

2019-06-20 Thread Carlos Manuel Duclos Vergara (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16868475#comment-16868475 ] Carlos Manuel Duclos Vergara commented on KAFKA-8342: - Any progress on this? Do you

[jira] [Created] (KAFKA-8572) Broker reports not leader partition as an error

2019-06-20 Thread Antony Stubbs (JIRA)
Antony Stubbs created KAFKA-8572: Summary: Broker reports not leader partition as an error Key: KAFKA-8572 URL: https://issues.apache.org/jira/browse/KAFKA-8572 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-8523) InsertField transformation fails when encountering tombstone event

2019-06-20 Thread Gunnar Morling (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16868422#comment-16868422 ] Gunnar Morling commented on KAFKA-8523: --- Good question, [~rhauch]; I didn't consider it, but I

[jira] [Resolved] (KAFKA-8564) NullPointerException when loading logs at startup

2019-06-20 Thread Edoardo Comar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Edoardo Comar resolved KAFKA-8564. -- Resolution: Fixed Fix Version/s: 2.2.2 2.1.2 2.3.0

[jira] [Commented] (KAFKA-8564) NullPointerException when loading logs at startup

2019-06-20 Thread Edoardo Comar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16868400#comment-16868400 ] Edoardo Comar commented on KAFKA-8564: -- This has been fixed by 

[jira] [Commented] (KAFKA-8536) Error creating ACL Alter Topic in 2.2

2019-06-20 Thread Alvaro Peris (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16868337#comment-16868337 ] Alvaro Peris commented on KAFKA-8536: - Hi @[Evelyn

[jira] [Assigned] (KAFKA-8078) Flaky Test TableTableJoinIntegrationTest#testInnerInner

2019-06-20 Thread Khaireddine Rezgui (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Khaireddine Rezgui reassigned KAFKA-8078: - Assignee: Khaireddine Rezgui > Flaky Test