[jira] [Commented] (KAFKA-8211) Flaky Test: ResetConsumerGroupOffsetTest.testResetOffsetsExportImportPlan

[ https://issues.apache.org/jira/browse/KAFKA-8211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16815064#comment-16815064 ] ASF GitHub Bot commented on KAFKA-8211: --- huxihx commented on pull request #6561: KAFKA-8211: Flaky

[jira] [Assigned] (KAFKA-8211) Flaky Test: ResetConsumerGroupOffsetTest.testResetOffsetsExportImportPlan

[ https://issues.apache.org/jira/browse/KAFKA-8211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx reassigned KAFKA-8211: - Assignee: huxihx > Flaky Test: ResetConsumerGroupOffsetTest.testResetOffsetsExportImportPlan >

[jira] [Resolved] (KAFKA-8161) Comma conflict when run script bin/kafka-configs.sh with config 'follower.replication.throttled.replicas'

[ https://issues.apache.org/jira/browse/KAFKA-8161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx resolved KAFKA-8161. --- Resolution: Not A Problem > Comma conflict when run script bin/kafka-configs.sh with config >

[jira] [Commented] (KAFKA-8161) Comma conflict when run script bin/kafka-configs.sh with config 'follower.replication.throttled.replicas'

[ https://issues.apache.org/jira/browse/KAFKA-8161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16815053#comment-16815053 ] Haiping commented on KAFKA-8161: h3. {color:#33}@huxihx  It worked. Thank you for your guidance.

[jira] [Commented] (KAFKA-8215) Limit memory usage of RocksDB

[ https://issues.apache.org/jira/browse/KAFKA-8215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16814992#comment-16814992 ] ASF GitHub Bot commented on KAFKA-8215: --- ableegoldman commented on pull request #6560: KAFKA-8215:

[jira] [Created] (KAFKA-8215) Limit memory usage of RocksDB

Sophie Blee-Goldman created KAFKA-8215: -- Summary: Limit memory usage of RocksDB Key: KAFKA-8215 URL: https://issues.apache.org/jira/browse/KAFKA-8215 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-8207) StickyPartitionAssignor for KStream

[ https://issues.apache.org/jira/browse/KAFKA-8207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16814976#comment-16814976 ] Matthias J. Sax commented on KAFKA-8207: That is by design. Kafka Streams' internal

[jira] [Commented] (KAFKA-8201) Kafka streams repartitioning topic settings crashing multiple nodes

[ https://issues.apache.org/jira/browse/KAFKA-8201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16814974#comment-16814974 ] Matthias J. Sax commented on KAFKA-8201: {quote}Another question here : Why use infinite

[jira] [Created] (KAFKA-8214) Handling RecordTooLargeException in the main thread

Mohan Parthasarathy created KAFKA-8214: -- Summary: Handling RecordTooLargeException in the main thread Key: KAFKA-8214 URL: https://issues.apache.org/jira/browse/KAFKA-8214 Project: Kafka

[jira] [Assigned] (KAFKA-6579) Consolidate window store and session store unit tests into a single class

[ https://issues.apache.org/jira/browse/KAFKA-6579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reassigned KAFKA-6579: -- Assignee: Sophie Blee-Goldman (was: Ben Webb) > Consolidate window store and

[jira] [Created] (KAFKA-8213) KStreams interactive query documentation typo

Michael Drogalis created KAFKA-8213: --- Summary: KStreams interactive query documentation typo Key: KAFKA-8213 URL: https://issues.apache.org/jira/browse/KAFKA-8213 Project: Kafka Issue

[jira] [Created] (KAFKA-8212) KStreams documentation Maven artifact table is cut off

Michael Drogalis created KAFKA-8212: --- Summary: KStreams documentation Maven artifact table is cut off Key: KAFKA-8212 URL: https://issues.apache.org/jira/browse/KAFKA-8212 Project: Kafka

[jira] [Created] (KAFKA-8211) Flaky Test: ResetConsumerGroupOffsetTest.testResetOffsetsExportImportPlan

Bill Bejeck created KAFKA-8211: -- Summary: Flaky Test: ResetConsumerGroupOffsetTest.testResetOffsetsExportImportPlan Key: KAFKA-8211 URL: https://issues.apache.org/jira/browse/KAFKA-8211 Project: Kafka

[jira] [Commented] (KAFKA-7937) Flaky Test ResetConsumerGroupOffsetTest.testResetOffsetsNotExistingGroup

[ https://issues.apache.org/jira/browse/KAFKA-7937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16814844#comment-16814844 ] Bill Bejeck commented on KAFKA-7937: Failed again 

[jira] [Created] (KAFKA-8210) Missing link for KStreams in Streams DSL docs

Michael Drogalis created KAFKA-8210: --- Summary: Missing link for KStreams in Streams DSL docs Key: KAFKA-8210 URL: https://issues.apache.org/jira/browse/KAFKA-8210 Project: Kafka Issue

[jira] [Assigned] (KAFKA-8208) Broken link for out-of-order data in KStreams Core Concepts doc

[ https://issues.apache.org/jira/browse/KAFKA-8208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-8208: -- Assignee: Bill Bejeck > Broken link for out-of-order data in KStreams Core Concepts doc >

[jira] [Created] (KAFKA-8209) Wrong link for KStreams DSL in Core Concepts doc

Michael Drogalis created KAFKA-8209: --- Summary: Wrong link for KStreams DSL in Core Concepts doc Key: KAFKA-8209 URL: https://issues.apache.org/jira/browse/KAFKA-8209 Project: Kafka Issue

[jira] [Updated] (KAFKA-8208) Broken link for out-of-order data in KStreams Core Concepts doc

[ https://issues.apache.org/jira/browse/KAFKA-8208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michael Drogalis updated KAFKA-8208: Issue Type: Bug (was: Improvement) > Broken link for out-of-order data in KStreams Core

[jira] [Created] (KAFKA-8208) Broken link for out-of-order data in KStreams Core Concepts doc

Michael Drogalis created KAFKA-8208: --- Summary: Broken link for out-of-order data in KStreams Core Concepts doc Key: KAFKA-8208 URL: https://issues.apache.org/jira/browse/KAFKA-8208 Project: Kafka

[jira] [Commented] (KAFKA-7378) Consumer poll hangs if broker shutdown while consumer attempting to connect.

[ https://issues.apache.org/jira/browse/KAFKA-7378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16814791#comment-16814791 ] John Calcote commented on KAFKA-7378: - Ping - anyone thinking about this issue? The problem exhibits

[jira] [Updated] (KAFKA-7895) Ktable supress operator emitting more than one record for the same key per window

[ https://issues.apache.org/jira/browse/KAFKA-7895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-7895: Fix Version/s: (was: 2.2.0) 2.2.1 > Ktable supress operator emitting more

[jira] [Updated] (KAFKA-8204) Streams may flush state stores in the incorrect order

[ https://issues.apache.org/jira/browse/KAFKA-8204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-8204: Fix Version/s: 2.2.1 2.1.2 > Streams may flush state stores in the incorrect

[jira] [Updated] (KAFKA-8204) Streams may flush state stores in the incorrect order

[ https://issues.apache.org/jira/browse/KAFKA-8204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-8204: Affects Version/s: 2.1.0 2.2.0 2.1.1 > Streams may

[jira] [Updated] (KAFKA-7895) Ktable supress operator emitting more than one record for the same key per window

[ https://issues.apache.org/jira/browse/KAFKA-7895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-7895: Affects Version/s: 2.2.0 > Ktable supress operator emitting more than one record for the same key

[jira] [Updated] (KAFKA-7895) Ktable supress operator emitting more than one record for the same key per window

[ https://issues.apache.org/jira/browse/KAFKA-7895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-7895: Priority: Blocker (was: Major) > Ktable supress operator emitting more than one record for the

[jira] [Updated] (KAFKA-8204) Streams may flush state stores in the incorrect order

[ https://issues.apache.org/jira/browse/KAFKA-8204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-8204: Priority: Blocker (was: Major) > Streams may flush state stores in the incorrect order >

[jira] [Reopened] (KAFKA-7895) Ktable supress operator emitting more than one record for the same key per window

[ https://issues.apache.org/jira/browse/KAFKA-7895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reopened KAFKA-7895: - > Ktable supress operator emitting more than one record for the same key per > window >

[jira] [Commented] (KAFKA-4336) Frequent log rolling when there's a mix of delayed and current data

[ https://issues.apache.org/jira/browse/KAFKA-4336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16814662#comment-16814662 ] Anders Aagaard commented on KAFKA-4336: --- This issue is possible to trigger with kafka-streams with

[jira] [Commented] (KAFKA-8201) Kafka streams repartitioning topic settings crashing multiple nodes

[ https://issues.apache.org/jira/browse/KAFKA-8201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16814661#comment-16814661 ] Anders Aagaard commented on KAFKA-8201: --- Thank you Bill   I figured this issue wouldn't and

[jira] [Assigned] (KAFKA-8200) TopologyTestDriver should offer an iterable signature of readOutput

[ https://issues.apache.org/jira/browse/KAFKA-8200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-8200: -- Assignee: Patrik Kleindl > TopologyTestDriver should offer an iterable signature of

[jira] [Created] (KAFKA-8207) StickyPartitionAssignor for KStream

neeraj created KAFKA-8207: - Summary: StickyPartitionAssignor for KStream Key: KAFKA-8207 URL: https://issues.apache.org/jira/browse/KAFKA-8207 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-5998) /.checkpoint.tmp Not found exception

[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16814356#comment-16814356 ] Tim Van Laer commented on KAFKA-5998: - Running kafka-streams 2.0.1 in Docker  {{$ cat

[jira] [Commented] (KAFKA-5998) /.checkpoint.tmp Not found exception

[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16814291#comment-16814291 ] Patrik Kleindl commented on KAFKA-5998: --- SUSE Linux Enterprise Server 12 SP3 4.4.176-94.88-default

[jira] [Comment Edited] (KAFKA-5998) /.checkpoint.tmp Not found exception

[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16814233#comment-16814233 ] Di Campo edited comment on KAFKA-5998 at 4/10/19 9:13 AM: -- It also happens to me

[jira] [Commented] (KAFKA-5998) /.checkpoint.tmp Not found exception

[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16814233#comment-16814233 ] Di Campo commented on KAFKA-5998: - It also happens to me on kafka_2.12-2.1.0. Run in AWS in docker (based

[jira] [Commented] (KAFKA-4453) add request prioritization

[ https://issues.apache.org/jira/browse/KAFKA-4453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16814078#comment-16814078 ] Di Shang commented on KAFKA-4453: - Hi The new metric introduced here breaks our metric parser with NaN