[jira] [Commented] (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:comment-tabpanel&focusedCommentId=16815115#comment-16815115 ] Matthias J. Sax commented on KAFKA-8200: Yes, it requires a KIP as indicated via

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

[ https://issues.apache.org/jira/browse/KAFKA-8214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8214: --- Environment: (was: Kafka version 1.0.2) > Handling RecordTooLargeException in the main thr

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

[ https://issues.apache.org/jira/browse/KAFKA-8214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8214: --- Affects Version/s: 1.0.2 > Handling RecordTooLargeException in the main thread > -

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

[ https://issues.apache.org/jira/browse/KAFKA-8214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8214: --- Component/s: streams > Handling RecordTooLargeException in the main thread > -

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

[ https://issues.apache.org/jira/browse/KAFKA-8213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-8213: -- Assignee: Victoria Bialas > KStreams interactive query documentation typo > --

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

[ https://issues.apache.org/jira/browse/KAFKA-8212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-8212: -- Assignee: Victoria Bialas > KStreams documentation Maven artifact table is cut off > -

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

[ https://issues.apache.org/jira/browse/KAFKA-8210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-8210: -- Assignee: Bill Bejeck > Missing link for KStreams in Streams DSL docs > --

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

[ https://issues.apache.org/jira/browse/KAFKA-8209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-8209: -- Assignee: Bill Bejeck > Wrong link for KStreams DSL in Core Concepts doc > ---

[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 ] Matthias J. Sax reassigned KAFKA-8208: -- Assignee: Bill Bejeck (was: Matthias J. Sax) > Broken link for out-of-order data in K

[jira] [Issue Comment Deleted] (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 ] Matthias J. Sax updated KAFKA-8208: --- Comment: was deleted (was: PR: [https://github.com/apache/kafka-site/pull/196]) > Broken lin

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

[ https://issues.apache.org/jira/browse/KAFKA-8209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-8209: -- Assignee: (was: Matthias J. Sax) > Wrong link for KStreams DSL in Core Concepts do

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

[ https://issues.apache.org/jira/browse/KAFKA-8209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-8209: -- Assignee: Matthias J. Sax > Wrong link for KStreams DSL in Core Concepts doc > ---

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=16815106#comment-16815106 ] Matthias J. Sax commented on KAFKA-8208: PR: [https://github.com/apache/kafka-sit

[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 ] Matthias J. Sax reassigned KAFKA-8208: -- Assignee: Matthias J. Sax (was: Bill Bejeck) > Broken link for out-of-order data in K

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

[ https://issues.apache.org/jira/browse/KAFKA-8214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16815097#comment-16815097 ] Matthias J. Sax commented on KAFKA-8214: Jira is not the way to ask question. You

[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&focusedCommentId=16815064#comment-16815064 ] ASF GitHub Bot commented on KAFKA-8211: --- huxihx commented on pull request #6561: KA

[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 > 'follower.rep

[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&focusedCommentId=16815053#comment-16815053 ] Haiping commented on KAFKA-8161: h3. {color:#33}@huxihx  It worked. Thank you for you

[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&focusedCommentId=16814992#comment-16814992 ] ASF GitHub Bot commented on KAFKA-8215: --- ableegoldman commented on pull request #65

[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: Improveme

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

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

[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&focusedCommentId=16814974#comment-16814974 ] Matthias J. Sax commented on KAFKA-8201: {quote}Another question here : Why use i

[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 Type:

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

[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&focusedCommentId=16814844#comment-16814844 ] Bill Bejeck commented on KAFKA-7937: Failed again [https://builds.apache.org/job/kafk

[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 Type:

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

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

[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&focusedCommentId=16814791#comment-16814791 ] John Calcote commented on KAFKA-7378: - Ping - anyone thinking about this issue? The p

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

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

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

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

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

[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&focusedCommentId=16814662#comment-16814662 ] Anders Aagaard commented on KAFKA-4336: --- This issue is possible to trigger with kaf

[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&focusedCommentId=16814661#comment-16814661 ] Anders Aagaard commented on KAFKA-8201: --- Thank you Bill   I figured this issue wo

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

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

[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&focusedCommentId=16814356#comment-16814356 ] Tim Van Laer commented on KAFKA-5998: - Running kafka-streams 2.0.1 in Docker  {{$ ca

[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&focusedCommentId=16814291#comment-16814291 ] Patrik Kleindl commented on KAFKA-5998: --- SUSE Linux Enterprise Server 12 SP3 4.4.1

[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&focusedCommentId=16814233#comment-16814233 ] Di Campo edited comment on KAFKA-5998 at 4/10/19 9:13 AM: -- It al

[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&focusedCommentId=16814233#comment-16814233 ] Di Campo edited comment on KAFKA-5998 at 4/10/19 9:13 AM: -- It al

[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&focusedCommentId=16814233#comment-16814233 ] Di Campo commented on KAFKA-5998: - It also happens to me on kafka_2.12-2.1.0. Run in AWS