[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=16836904#comment-16836904 ] ASF GitHub Bot commented on KAFKA-8344: --- gwenshap commented on pull request #6703: KAFKA-8344. Fix

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

[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=16836852#comment-16836852 ] Sagar Rao commented on KAFKA-7206: -- Hi [~shung], [~guozhang] Is it something that I can pick up? >

[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=16836820#comment-16836820 ] Boyang Chen commented on KAFKA-8230: [~ijuma] woo, miss this point! > Add static membership support

[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=16836819#comment-16836819 ] ASF GitHub Bot commented on KAFKA-8231: --- rhauch commented on pull request #6584: KAFKA-8231:

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

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

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

[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,

[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

[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=16836801#comment-16836801 ] Guozhang Wang commented on KAFKA-8313: -- Hello [~ladoe00] Looking at your description I feel it is

[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=16836802#comment-16836802 ] Guozhang Wang commented on KAFKA-8313: -- Just a few more words on why the threads' being shutdown:

[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

[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

[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=16836770#comment-16836770 ] Guozhang Wang commented on KAFKA-8342: -- [~pkleindl] thanks for sharing your use case, I think we

[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=16836755#comment-16836755 ] ASF GitHub Bot commented on KAFKA-8324: --- bbejeck commented on pull request #6697: KAFKA-8324: Add

[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=16836746#comment-16836746 ] ASF GitHub Bot commented on KAFKA-6789: --- hachikuji commented on pull request #5578: KAFKA-6789:

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

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

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

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

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

[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=16836596#comment-16836596 ] ASF GitHub Bot commented on KAFKA-8332: --- cmccabe commented on pull request #6626: KAFKA-8332:

[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

[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) > - > >

[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

[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.

[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

[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=16836058#comment-16836058 ] Ryanne Dolan edited comment on KAFKA-7500 at 5/9/19 2:41 PM: - [~cloudfrog],

[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=16836432#comment-16836432 ] Frederic Tardif commented on KAFKA-7849: got the same issue: {code:java} [2019-05-08

[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

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

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

[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=16836374#comment-16836374 ] Raoul de Haard commented on KAFKA-1194: --- Any updates on when this issue is being merged?

[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=16836347#comment-16836347 ] Matthias J. Sax commented on KAFKA-8343: I don't think that the code is executed in a different

[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=16836320#comment-16836320 ] Ferlin-Sutton Léo commented on KAFKA-7362: -- I can see the implementation is being worked on and

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

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

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

[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=16836232#comment-16836232 ] Patrik Kleindl commented on KAFKA-8342: --- This sounds very interesting, I hope it is ok if I add our

[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=16836193#comment-16836193 ] Adam Antal commented on KAFKA-8146: --- Hi, This error is the same as in HADOOP-10848. This is due to

[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=16836176#comment-16836176 ] ASF GitHub Bot commented on KAFKA-8344: --- sekikn commented on pull request #6703: KAFKA-8344. Fix

[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