[jira] [Commented] (KAFKA-8348) Document of kafkaStreams improvement

[ https://issues.apache.org/jira/browse/KAFKA-8348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16836924#comment-16836924 ] Lifei Chen commented on KAFKA-8348: --- Hi [~mjsax],  I am starting to read and contribute

[jira] [Updated] (KAFKA-8348) Document of kafkaStreams improvement

[ https://issues.apache.org/jira/browse/KAFKA-8348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lifei Chen updated KAFKA-8348: -- Reviewer: Matthias J. Sax > Document of kafkaStreams improvement >

[jira] [Commented] (KAFKA-8348) Document of kafkaStreams improvement

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

[jira] [Created] (KAFKA-8348) Document of kafkaStreams improvement

Lifei Chen created KAFKA-8348: - Summary: Document of kafkaStreams improvement Key: KAFKA-8348 URL: https://issues.apache.org/jira/browse/KAFKA-8348 Project: Kafka Issue Type: Improvement

[jira] [Resolved] (KAFKA-8344) Fix vagrant-up.sh to work with AWS properly

[ https://issues.apache.org/jira/browse/KAFKA-8344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira resolved KAFKA-8344. - Resolution: Fixed Fix Version/s: 2.3.0 > Fix vagrant-up.sh to work with AWS properly > ---

[jira] [Commented] (KAFKA-8344) Fix vagrant-up.sh to work with AWS properly

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

[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=16836879#comment-16836879 ] WooYoung commented on KAFKA-8311: - [~mjsax], [~bchen225242] Thanks~ I have checked the d

[jira] [Commented] (KAFKA-7206) Enable batching in FindCoordinator

[ https://issues.apache.org/jira/browse/KAFKA-7206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16836852#comment-16836852 ] Sagar Rao commented on KAFKA-7206: -- Hi [~shung], [~guozhang] Is it something that I can

[jira] [Resolved] (KAFKA-8231) Expansion of ConnectClusterState interface

[ https://issues.apache.org/jira/browse/KAFKA-8231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch resolved KAFKA-8231. -- Resolution: Fixed > Expansion of ConnectClusterState interface > --

[jira] [Commented] (KAFKA-8230) Add static membership support in librd consumer client

[ https://issues.apache.org/jira/browse/KAFKA-8230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16836820#comment-16836820 ] Boyang Chen commented on KAFKA-8230: [~ijuma] woo, miss this point! > Add static mem

[jira] [Commented] (KAFKA-8231) Expansion of ConnectClusterState interface

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

[jira] [Comment Edited] (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=16836813#comment-16836813 ] Boyang Chen edited comment on KAFKA-8311 at 5/10/19 1:09 AM: -

[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=16836813#comment-16836813 ] Boyang Chen commented on KAFKA-8311: [~mjsax] [~clearpal7] Thank you both! If you won

[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=16836811#comment-16836811 ] Jason Gustafson commented on KAFKA-8335: Thanks for the additional information. T

[jira] [Assigned] (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 ] Jason Gustafson reassigned KAFKA-8335: -- Assignee: Jason Gustafson > Log cleaner skips Transactional mark and batch record, cau

[jira] [Resolved] (KAFKA-8313) KafkaStreams state not being updated properly after shutdown

[ https://issues.apache.org/jira/browse/KAFKA-8313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-8313. -- Resolution: Fixed Assignee: Guozhang Wang Fix Version/s: 2.3.0 > KafkaStreams s

[jira] [Commented] (KAFKA-8313) KafkaStreams state not being updated properly after shutdown

[ https://issues.apache.org/jira/browse/KAFKA-8313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16836801#comment-16836801 ] Guozhang Wang commented on KAFKA-8313: -- Hello [~ladoe00] Looking at your description

[jira] [Commented] (KAFKA-8313) KafkaStreams state not being updated properly after shutdown

[ https://issues.apache.org/jira/browse/KAFKA-8313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16836802#comment-16836802 ] Guozhang Wang commented on KAFKA-8313: -- Just a few more words on why the threads' be

[jira] [Created] (KAFKA-8347) Choose next record to process by timestamp

Sophie Blee-Goldman created KAFKA-8347: -- Summary: Choose next record to process by timestamp Key: KAFKA-8347 URL: https://issues.apache.org/jira/browse/KAFKA-8347 Project: Kafka Issue Ty

[jira] [Created] (KAFKA-8346) Improve replica fetcher behavior in handling partition failures

Aishwarya Gune created KAFKA-8346: - Summary: Improve replica fetcher behavior in handling partition failures Key: KAFKA-8346 URL: https://issues.apache.org/jira/browse/KAFKA-8346 Project: Kafka

[jira] [Resolved] (KAFKA-6789) Add retry logic in AdminClient requests

[ https://issues.apache.org/jira/browse/KAFKA-6789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6789. Resolution: Fixed Fix Version/s: 2.2.2 2.1.2 2.

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=16836770#comment-16836770 ] Guozhang Wang commented on KAFKA-8342: -- [~pkleindl] thanks for sharing your use case

[jira] [Updated] (KAFKA-8231) Expansion of ConnectClusterState interface

[ https://issues.apache.org/jira/browse/KAFKA-8231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-8231: - Fix Version/s: 2.3.0 > Expansion of ConnectClusterState interface > -

[jira] [Commented] (KAFKA-8324) User constructed RocksObjects leak memory

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

[jira] [Commented] (KAFKA-6789) Add retry logic in AdminClient requests

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

[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=16836735#comment-16836735 ] Andrew edited comment on KAFKA-8315 at 5/9/19 10:04 PM: Thanks [~

[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=16836735#comment-16836735 ] Andrew edited comment on KAFKA-8315 at 5/9/19 10:03 PM: Thanks [~

[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=16836735#comment-16836735 ] Andrew edited comment on KAFKA-8315 at 5/9/19 9:59 PM: --- Thanks [~ab

[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=16836735#comment-16836735 ] Andrew commented on KAFKA-8315: --- Thanks [~ableegoldman] and [~vvcephei]. I have today trie

[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=16836606#comment-16836606 ] Sophie Blee-Goldman commented on KAFKA-8315: [~the4thamigo_uk] The code you'r

[jira] [Commented] (KAFKA-8332) Regression in handling of JoinGroupRequest disallows deterministic protocol selection based on order of preference

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

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

[ https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ryanne Dolan reassigned KAFKA-7500: --- Assignee: Colin P. McCabe (was: Ryanne Dolan) Reviewer: Colin P. McCabe [https://github

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

[ https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ryanne Dolan updated KAFKA-7500: Fix Version/s: 2.3.0 > MirrorMaker 2.0 (KIP-382) > - > > Ke

[jira] [Assigned] (KAFKA-8001) Fetch from future replica stalls when local replica becomes a leader

[ https://issues.apache.org/jira/browse/KAFKA-8001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vikas Singh reassigned KAFKA-8001: -- Assignee: Vikas Singh (was: Colin Hicks) > Fetch from future replica stalls when local replic

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

[ https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ryanne Dolan updated KAFKA-7500: Description: Implement a drop-in replacement for MirrorMaker leveraging the Connect framework. [h

[jira] [Created] (KAFKA-8345) Create an Administrative API for Replica Reassignment

Colin P. McCabe created KAFKA-8345: -- Summary: Create an Administrative API for Replica Reassignment Key: KAFKA-8345 URL: https://issues.apache.org/jira/browse/KAFKA-8345 Project: Kafka Issue

[jira] [Comment Edited] (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 edited comment on KAFKA-7500 at 5/9/19 2:41 PM: -

[jira] [Commented] (KAFKA-7849) Warning when adding GlobalKTable

[ https://issues.apache.org/jira/browse/KAFKA-7849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16836432#comment-16836432 ] Frederic Tardif commented on KAFKA-7849: got the same issue: {code:java} [2019-05

[jira] [Updated] (KAFKA-7805) Use --bootstrap-server option for kafka-topics.sh in ducktape tests where applicable

[ https://issues.apache.org/jira/browse/KAFKA-7805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Viktor Somogyi-Vass updated KAFKA-7805: --- Summary: Use --bootstrap-server option for kafka-topics.sh in ducktape tests where ap

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

[ https://issues.apache.org/jira/browse/KAFKA-8240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-8240. Resolution: Fixed Fix Version/s: 2.2.2 2.1.2 2.

[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=16836397#comment-16836397 ] ASF GitHub Bot commented on KAFKA-8240: --- mjsax commented on pull request #6685: KAF

[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=16836381#comment-16836381 ] Matthias J. Sax commented on KAFKA-8311: Thanks for you interest [~clearpal7]! I

[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 ] Matthias J. Sax reassigned KAFKA-8311: -- Assignee: WooYoung > Better consumer timeout exception handling > ---

[jira] [Updated] (KAFKA-8332) Regression in handling of JoinGroupRequest disallows deterministic protocol selection based on order of preference

[ https://issues.apache.org/jira/browse/KAFKA-8332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-8332: --- Fix Version/s: 2.3.0 > Regression in handling of JoinGroupRequest disallows deterministic protocol >

[jira] [Commented] (KAFKA-1194) The kafka broker cannot delete the old log files after the configured time

[ https://issues.apache.org/jira/browse/KAFKA-1194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16836374#comment-16836374 ] Raoul de Haard commented on KAFKA-1194: --- Any updates on when this issue is being me

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

[ https://issues.apache.org/jira/browse/KAFKA-8343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16836347#comment-16836347 ] Matthias J. Sax commented on KAFKA-8343: I don't think that the code is executed

[jira] [Commented] (KAFKA-7362) enable kafka broker to remove orphan partitions automatically

[ https://issues.apache.org/jira/browse/KAFKA-7362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16836320#comment-16836320 ] Ferlin-Sutton Léo commented on KAFKA-7362: -- I can see the implementation is bein

[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=16836278#comment-16836278 ] Andrew edited comment on KAFKA-8315 at 5/9/19 10:58 AM: [~vvcephe

[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=16836278#comment-16836278 ] Andrew edited comment on KAFKA-8315 at 5/9/19 10:57 AM: Ok, so it

[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=16836278#comment-16836278 ] Andrew edited comment on KAFKA-8315 at 5/9/19 10:57 AM: Ok, so it

[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=16836278#comment-16836278 ] Andrew edited comment on KAFKA-8315 at 5/9/19 10:56 AM: Ok, so it

[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=16836278#comment-16836278 ] Andrew edited comment on KAFKA-8315 at 5/9/19 10:43 AM: Ok, so it

[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=16836278#comment-16836278 ] Andrew commented on KAFKA-8315: --- Ok, so it should work as I had previously hoped, so maybe

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=16836232#comment-16836232 ] Patrik Kleindl commented on KAFKA-8342: --- This sounds very interesting, I hope it is

[jira] [Commented] (KAFKA-8146) WARNING: An illegal reflective access operation has occurred

[ https://issues.apache.org/jira/browse/KAFKA-8146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16836193#comment-16836193 ] Adam Antal commented on KAFKA-8146: --- Hi, This error is the same as in HADOOP-10848. Th

[jira] [Commented] (KAFKA-8344) Fix vagrant-up.sh to work with AWS properly

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

[jira] [Created] (KAFKA-8344) Fix vagrant-up.sh to work with AWS properly

Kengo Seki created KAFKA-8344: - Summary: Fix vagrant-up.sh to work with AWS properly Key: KAFKA-8344 URL: https://issues.apache.org/jira/browse/KAFKA-8344 Project: Kafka Issue Type: Bug