[jira] [Assigned] (KAFKA-8062) StateListener is not notified when StreamThread dies

2019-03-19 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-8062: -- Assignee: Guozhang Wang (was: Bill Bejeck) > StateListener is not notified when StreamThread

[jira] [Resolved] (KAFKA-8062) StateListener is not notified when StreamThread dies

2019-03-19 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8062. Resolution: Fixed > StateListener is not notified when StreamThread dies >

[jira] [Commented] (KAFKA-8062) StateListener is not notified when StreamThread dies

2019-03-19 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16796140#comment-16796140 ] Bill Bejeck commented on KAFKA-8062: cherry-picked to 2.2 as well > StateListener is

[jira] [Assigned] (KAFKA-8094) Iterating over cache with get(key) is inefficient

2019-03-19 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-8094: -- Assignee: Sophie Blee-Goldman > Iterating over cache with get(key) is inefficient > -

[jira] [Resolved] (KAFKA-8094) Iterating over cache with get(key) is inefficient

2019-03-19 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8094. Resolution: Fixed > Iterating over cache with get(key) is inefficient > --

[jira] [Commented] (KAFKA-7996) KafkaStreams does not pass timeout when closing Producer

2019-03-20 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16797555#comment-16797555 ] Bill Bejeck commented on KAFKA-7996: IMHO we should go ahead and add a config for a "

[jira] [Assigned] (KAFKA-8147) Add changelog topic configuration to KTable suppress

2019-03-23 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-8147: -- Assignee: Maarten > Add changelog topic configuration to KTable suppress > ---

[jira] [Commented] (KAFKA-8147) Add changelog topic configuration to KTable suppress

2019-03-23 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16799819#comment-16799819 ] Bill Bejeck commented on KAFKA-8147: [~mjduijn]   I've added you to the contributors

[jira] [Comment Edited] (KAFKA-8147) Add changelog topic configuration to KTable suppress

2019-03-23 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16799819#comment-16799819 ] Bill Bejeck edited comment on KAFKA-8147 at 3/23/19 10:25 PM: -

[jira] [Commented] (KAFKA-8147) Add changelog topic configuration to KTable suppress

2019-03-24 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16800112#comment-16800112 ] Bill Bejeck commented on KAFKA-8147: Hi [~mjduijn] Thanks for setting up the Apache

[jira] [Resolved] (KAFKA-6399) Consider reducing "max.poll.interval.ms" default for Kafka Streams

2019-04-04 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-6399. Resolution: Fixed > Consider reducing "max.poll.interval.ms" default for Kafka Streams > --

[jira] [Created] (KAFKA-8199) ClassCastException when trying to groupBy after suppress

2019-04-08 Thread Bill Bejeck (JIRA)
Bill Bejeck created KAFKA-8199: -- Summary: ClassCastException when trying to groupBy after suppress Key: KAFKA-8199 URL: https://issues.apache.org/jira/browse/KAFKA-8199 Project: Kafka Issue Type

[jira] [Updated] (KAFKA-8199) ClassCastException when trying to groupBy after suppress

2019-04-08 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8199: --- Description: A topology with a groupBy after a suppress operation results in a ClassCastException  

[jira] [Updated] (KAFKA-8199) ClassCastException when trying to groupBy after suppress

2019-04-08 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8199: --- Description: A topology with a groupBy after a suppress operation results in a ClassCastException  

[jira] [Updated] (KAFKA-8199) ClassCastException when trying to groupBy after suppress

2019-04-08 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8199: --- Description: A topology with a groupBy after a suppress operation results in a ClassCastException  

[jira] [Updated] (KAFKA-8199) ClassCastException when trying to groupBy after suppress

2019-04-08 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8199: --- Description: A topology with a groupBy after a suppress operation results in a ClassCastException  

[jira] [Commented] (KAFKA-7965) Flaky Test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

2019-04-09 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16813425#comment-16813425 ] Bill Bejeck commented on KAFKA-7965: Saw this failure again  [https://builds.apache.o

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

2019-04-09 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16813573#comment-16813573 ] Bill Bejeck commented on KAFKA-8201: Hi Anders Aagaard, I'm not sure this is a bug f

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

2019-04-10 Thread Bill Bejeck (JIRA)
[ 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] [Assigned] (KAFKA-8208) Broken link for out-of-order data in KStreams Core Concepts doc

2019-04-10 Thread Bill Bejeck (JIRA)
[ 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] [Commented] (KAFKA-7937) Flaky Test ResetConsumerGroupOffsetTest.testResetOffsetsNotExistingGroup

2019-04-10 Thread Bill Bejeck (JIRA)
[ 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-8211) Flaky Test: ResetConsumerGroupOffsetTest.testResetOffsetsExportImportPlan

2019-04-10 Thread Bill Bejeck (JIRA)
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] [Created] (KAFKA-8227) Missing Links in Duality of Streams and Tables section

2019-04-12 Thread Bill Bejeck (JIRA)
Bill Bejeck created KAFKA-8227: -- Summary: Missing Links in Duality of Streams and Tables section Key: KAFKA-8227 URL: https://issues.apache.org/jira/browse/KAFKA-8227 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-8187) State store record loss across multiple reassignments when using standby tasks

2019-04-12 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16816676#comment-16816676 ] Bill Bejeck commented on KAFKA-8187: Hi, [~wgreerx] just touching base to see if you

[jira] [Commented] (KAFKA-7965) Flaky Test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

2019-04-12 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16816689#comment-16816689 ] Bill Bejeck commented on KAFKA-7965: failed again [https://builds.apache.org/job/kafk

[jira] [Assigned] (KAFKA-8187) State store record loss across multiple reassignments when using standby tasks

2019-04-12 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-8187: -- Assignee: Bill Bejeck > State store record loss across multiple reassignments when using stand

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

2019-04-13 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8208. Resolution: Fixed Fix Version/s: 2.3.0 > Broken link for out-of-order data in KStreams Core

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

2019-04-13 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8210: --- Fix Version/s: 2.3.0 > Missing link for KStreams in Streams DSL docs > --

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

2019-04-13 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8210. Resolution: Fixed > Missing link for KStreams in Streams DSL docs > ---

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

2019-04-13 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8209: --- Fix Version/s: 2.3.0 > Wrong link for KStreams DSL in Core Concepts doc > ---

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

2019-04-13 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8209. Resolution: Fixed > 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

2019-04-16 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16819057#comment-16819057 ] Bill Bejeck commented on KAFKA-8208: cherry-picked to 2.2 and 2.1 > Broken link for

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

2019-04-16 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8208: --- Fix Version/s: 2.1.0 2.2.0 > Broken link for out-of-order data in KStreams Core Co

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

2019-04-16 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16819096#comment-16819096 ] Bill Bejeck commented on KAFKA-8209: cherry-picked to 2.2, 2.1, 2.0, 1.1 and 1.0 > W

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

2019-04-16 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8209: --- Fix Version/s: 1.0.0 1.1.0 2.0.0 2.1.0

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

2019-04-16 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8210: --- Fix Version/s: 2.1.0 2.2.0 > Missing link for KStreams in Streams DSL docs > -

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

2019-04-16 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16819149#comment-16819149 ] Bill Bejeck commented on KAFKA-8210: cherry-picked to 2.2, 2.1 and 2.0 > Missing lin

[jira] [Commented] (KAFKA-7965) Flaky Test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

2019-04-16 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16819185#comment-16819185 ] Bill Bejeck commented on KAFKA-7965: [https://builds.apache.org/job/kafka-pr-jdk8-sca

[jira] [Resolved] (KAFKA-7875) Add KStream#flatTransformValues

2019-04-16 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-7875. Resolution: Fixed > Add KStream#flatTransformValues > --- > >

[jira] [Updated] (KAFKA-7875) Add KStream#flatTransformValues

2019-04-16 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-7875: --- Fix Version/s: 2.3.0 > Add KStream#flatTransformValues > --- > >

[jira] [Commented] (KAFKA-7965) Flaky Test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

2019-04-16 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16819432#comment-16819432 ] Bill Bejeck commented on KAFKA-7965: [https://builds.apache.org/job/kafka-pr-jdk8-sca

[jira] [Commented] (KAFKA-7965) Flaky Test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

2019-04-18 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16821276#comment-16821276 ] Bill Bejeck commented on KAFKA-7965: Failed again,  [https://builds.apache.org/job/k

[jira] [Commented] (KAFKA-7965) Flaky Test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

2019-04-19 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16822208#comment-16822208 ] Bill Bejeck commented on KAFKA-7965: Got another one [https://builds.apache.org/job/

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

2019-04-20 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-7895. Resolution: Fixed > Ktable supress operator emitting more than one record for the same key per > w

[jira] [Commented] (KAFKA-7965) Flaky Test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

2019-04-22 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16823533#comment-16823533 ] Bill Bejeck commented on KAFKA-7965: Saw this on 2.2 looks like a different error  

[jira] [Updated] (KAFKA-8227) Missing Links in Duality of Streams and Tables section

2019-04-24 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8227: --- Fix Version/s: 2.2.1 2.1.2 2.3.0 2.0.2 > Mis

[jira] [Resolved] (KAFKA-8227) Missing Links in Duality of Streams and Tables section

2019-04-24 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8227. Resolution: Fixed > Missing Links in Duality of Streams and Tables section > --

[jira] [Commented] (KAFKA-8227) Missing Links in Duality of Streams and Tables section

2019-04-24 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16825540#comment-16825540 ] Bill Bejeck commented on KAFKA-8227: Merged to trunk and cherry-picked to 2.2, 2.1 an

[jira] [Created] (KAFKA-8290) Streams Not Closing Fenced Producer On Task Close

2019-04-25 Thread Bill Bejeck (JIRA)
Bill Bejeck created KAFKA-8290: -- Summary: Streams Not Closing Fenced Producer On Task Close Key: KAFKA-8290 URL: https://issues.apache.org/jira/browse/KAFKA-8290 Project: Kafka Issue Type: Bug

[jira] [Updated] (KAFKA-8290) Streams Not Closing Fenced Producer On Task Close

2019-04-25 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8290: --- Description: When a producer is fenced during processing and a rebalance is triggered, streams closes

[jira] [Updated] (KAFKA-8290) Streams Not Closing Fenced Producer On Task Close

2019-04-25 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8290: --- Description: When a producer is fenced during processing and a rebalance is triggered, Kafka Streams

[jira] [Updated] (KAFKA-8290) Streams Not Closing Fenced Producer On Task Close

2019-04-25 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8290: --- Description: When a producer is fenced during processing a rebalance is triggered and Kafka Streams c

[jira] [Created] (KAFKA-8298) ConcurrentModificationException Possible when optimizing for repartition nodes

2019-04-26 Thread Bill Bejeck (JIRA)
Bill Bejeck created KAFKA-8298: -- Summary: ConcurrentModificationException Possible when optimizing for repartition nodes Key: KAFKA-8298 URL: https://issues.apache.org/jira/browse/KAFKA-8298 Project: Kaf

[jira] [Commented] (KAFKA-8317) ClassCastException using KTable.suppress()

2019-05-02 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16831842#comment-16831842 ] Bill Bejeck commented on KAFKA-8317: Hi [~the4thamigo_uk], I don't think you are doi

[jira] [Issue Comment Deleted] (KAFKA-8317) ClassCastException using KTable.suppress()

2019-05-02 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8317: --- Comment: was deleted (was: Hi [~the4thamigo_uk], I don't think you are doing anything wrong, looks l

[jira] [Comment Edited] (KAFKA-8317) ClassCastException using KTable.suppress()

2019-05-02 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16831864#comment-16831864 ] Bill Bejeck edited comment on KAFKA-8317 at 5/2/19 6:58 PM: H

[jira] [Commented] (KAFKA-8317) ClassCastException using KTable.suppress()

2019-05-02 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16831864#comment-16831864 ] Bill Bejeck commented on KAFKA-8317: Hi [~the4thamigo_uk], Thanks for reporting this

[jira] [Created] (KAFKA-8319) Flaky Test KafkaStreamsTest.statefulTopologyShouldCreateStateDirectory

2019-05-03 Thread Bill Bejeck (JIRA)
Bill Bejeck created KAFKA-8319: -- Summary: Flaky Test KafkaStreamsTest.statefulTopologyShouldCreateStateDirectory Key: KAFKA-8319 URL: https://issues.apache.org/jira/browse/KAFKA-8319 Project: Kafka

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

2019-05-03 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8240. Resolution: Fixed > Source.equals() can fail with NPE > - > >

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

2019-05-03 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reopened KAFKA-8240: This needs to get cherry-picked back to 2.2 and 2.1 so reopening.  I'll resolve once that happens. >

[jira] [Created] (KAFKA-8321) Flaky Test kafka.server.DynamicConfigTest.shouldFailWhenChangingClientIdUnknownConfig

2019-05-03 Thread Bill Bejeck (JIRA)
Bill Bejeck created KAFKA-8321: -- Summary: Flaky Test kafka.server.DynamicConfigTest.shouldFailWhenChangingClientIdUnknownConfig Key: KAFKA-8321 URL: https://issues.apache.org/jira/browse/KAFKA-8321 Proje

[jira] [Resolved] (KAFKA-8323) Memory leak of BloomFilter Rocks object

2019-05-03 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8323. Resolution: Fixed cherry-picked to 2.2 as well > Memory leak of BloomFilter Rocks object > ---

[jira] [Commented] (KAFKA-8323) Memory leak of BloomFilter Rocks object

2019-05-04 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16833083#comment-16833083 ] Bill Bejeck commented on KAFKA-8323: cherry-picked [https://github.com/apache/kafka/p

[jira] [Resolved] (KAFKA-8319) Flaky Test KafkaStreamsTest.statefulTopologyShouldCreateStateDirectory

2019-05-06 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8319. Resolution: Cannot Reproduce > Flaky Test KafkaStreamsTest.statefulTopologyShouldCreateStateDirecto

[jira] [Commented] (KAFKA-8319) Flaky Test KafkaStreamsTest.statefulTopologyShouldCreateStateDirectory

2019-05-06 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16834033#comment-16834033 ] Bill Bejeck commented on KAFKA-8319: Hi [~ckamal], I don't have it anymore, but I've

[jira] [Assigned] (KAFKA-8187) State store record loss across multiple reassignments when using standby tasks

2019-05-10 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-8187: -- Assignee: Bill Bejeck (was: Matthias J. Sax) > State store record loss across multiple reassi

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

2019-05-16 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8347: --- Fix Version/s: 2.3.0 > Choose next record to process by timestamp > -

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

2019-05-16 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8347: --- Affects Version/s: 2.3.0 > Choose next record to process by timestamp > -

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

2019-05-17 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-8215: -- Assignee: Bill Bejeck > Limit memory usage of RocksDB > - > >

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

2019-05-17 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-8215: -- Assignee: Sophie Blee-Goldman (was: Bill Bejeck) > Limit memory usage of RocksDB > --

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

2019-05-17 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16842620#comment-16842620 ] Bill Bejeck commented on KAFKA-8347: cherry-picked to 2.2 and 2.1 > Choose next reco

[jira] [Updated] (KAFKA-8290) Streams Not Closing Fenced Producer On Task Close

2019-05-20 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8290: --- Affects Version/s: 2.0.0 2.1.0 2.2.0 > Streams Not Clos

[jira] [Updated] (KAFKA-8290) Streams Not Closing Fenced Producer On Task Close

2019-05-20 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8290: --- Fix Version/s: 2.2.2 2.1.2 2.3.0 > Streams Not Closing Fenced P

[jira] [Updated] (KAFKA-8290) Streams Not Closing Fenced Producer On Task Close

2019-05-20 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8290: --- Fix Version/s: 2.0.2 > Streams Not Closing Fenced Producer On Task Close > --

[jira] [Commented] (KAFKA-8290) Streams Not Closing Fenced Producer On Task Close

2019-05-20 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16843982#comment-16843982 ] Bill Bejeck commented on KAFKA-8290: cherry-picked to 2.2, 2.1 and 2.0 > Streams Not

[jira] [Resolved] (KAFKA-8399) Add back `internal.leave.group.on.close` config for KStreams

2019-05-22 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8399. Resolution: Fixed > Add back `internal.leave.group.on.close` config for KStreams >

[jira] [Comment Edited] (KAFKA-7201) Optimize repartition operations

2019-05-23 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16846795#comment-16846795 ] Bill Bejeck edited comment on KAFKA-7201 at 5/23/19 3:37 PM: -

[jira] [Commented] (KAFKA-7201) Optimize repartition operations

2019-05-23 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16846795#comment-16846795 ] Bill Bejeck commented on KAFKA-7201: [~mjsax] Apologies for the delayed response.  Y

[jira] [Resolved] (KAFKA-7201) Optimize repartition operations

2019-05-23 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-7201. Resolution: Fixed Resolved via https://issues.apache.org/jira/browse/KAFKA-6761  > Optimize repart

[jira] [Updated] (KAFKA-7201) Optimize repartition operations

2019-05-23 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-7201: --- Fix Version/s: 2.1.0 > Optimize repartition operations > --- > >

[jira] [Updated] (KAFKA-7201) Optimize repartition operations

2019-05-23 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-7201: --- Affects Version/s: 2.1.0 > Optimize repartition operations > --- > >

[jira] [Commented] (KAFKA-8413) Add possibility to do repartitioning on KStream

2019-05-23 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16846905#comment-16846905 ] Bill Bejeck commented on KAFKA-8413: Hi, [~lkokhreidze] thanks for reporting this.  

[jira] [Updated] (KAFKA-8416) Improve Documentation for Enabling Optimizations

2019-05-23 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8416: --- Component/s: streams > Improve Documentation for Enabling Optimizations > ---

[jira] [Updated] (KAFKA-8416) Improve Documentation for Enabling Optimizations

2019-05-23 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8416: --- Labels: newbie, (was: ) > Improve Documentation for Enabling Optimizations > ---

[jira] [Created] (KAFKA-8416) Improve Documentation for Enabling Optimizations

2019-05-23 Thread Bill Bejeck (JIRA)
Bill Bejeck created KAFKA-8416: -- Summary: Improve Documentation for Enabling Optimizations Key: KAFKA-8416 URL: https://issues.apache.org/jira/browse/KAFKA-8416 Project: Kafka Issue Type: Improv

[jira] [Commented] (KAFKA-8413) Add possibility to do repartitioning on KStream

2019-05-23 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16846927#comment-16846927 ] Bill Bejeck commented on KAFKA-8413: Hi [~lkokhreidze], No problem at all!  It's a s

[jira] [Resolved] (KAFKA-8413) Add possibility to do repartitioning on KStream

2019-05-23 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8413. Resolution: Not A Problem > Add possibility to do repartitioning on KStream > -

[jira] [Assigned] (KAFKA-8187) State store record loss across multiple reassignments when using standby tasks

2019-05-28 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-8187: -- Assignee: Lifei Chen (was: Bill Bejeck) > State store record loss across multiple reassignmen

[jira] [Commented] (KAFKA-8187) State store record loss across multiple reassignments when using standby tasks

2019-05-28 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16849915#comment-16849915 ] Bill Bejeck commented on KAFKA-8187: Hi [~hustclf] I've assigned the ticket to you. 

[jira] [Comment Edited] (KAFKA-8187) State store record loss across multiple reassignments when using standby tasks

2019-05-28 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16849915#comment-16849915 ] Bill Bejeck edited comment on KAFKA-8187 at 5/28/19 4:42 PM: -

[jira] [Updated] (KAFKA-8187) State store record loss across multiple reassignments when using standby tasks

2019-05-30 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8187: --- Fix Version/s: 2.2.1 2.1.2 2.3.0 > State store record loss acro

[jira] [Resolved] (KAFKA-8187) State store record loss across multiple reassignments when using standby tasks

2019-05-30 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8187. Resolution: Fixed merged to trunk and cherry-picked to 2.3, 2.2 and 2.1 > State store record loss

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

2019-05-30 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-5998: -- Assignee: Bill Bejeck > /.checkpoint.tmp Not found exception > ---

[jira] [Created] (KAFKA-8469) Named Suppress Operator Needs to increment Name Counter

2019-06-03 Thread Bill Bejeck (JIRA)
Bill Bejeck created KAFKA-8469: -- Summary: Named Suppress Operator Needs to increment Name Counter Key: KAFKA-8469 URL: https://issues.apache.org/jira/browse/KAFKA-8469 Project: Kafka Issue Type:

[jira] [Resolved] (KAFKA-8469) Named Suppress Operator Needs to increment Name Counter

2019-06-03 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8469. Resolution: Not A Problem > Named Suppress Operator Needs to increment Name Counter > -

[jira] [Assigned] (KAFKA-7760) Add broker configuration to set minimum value for segment.bytes and segment.ms

2019-06-06 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-7760: -- Assignee: Dulvin Witharane > Add broker configuration to set minimum value for segment.bytes a

[jira] [Commented] (KAFKA-8461) Flakey test UncleanLeaderElectionTest#testUncleanLeaderElectionDisabledByTopicOverride

2019-06-07 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16858940#comment-16858940 ] Bill Bejeck commented on KAFKA-8461: Saw another instance of this [https://builds.ap

[jira] [Resolved] (KAFKA-8331) Add system test for enabling static membership on KStream

2019-06-07 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8331. Resolution: Fixed > Add system test for enabling static membership on KStream > ---

[jira] [Updated] (KAFKA-8331) Add system test for enabling static membership on KStream

2019-06-07 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8331: --- Fix Version/s: 2.4.0 > Add system test for enabling static membership on KStream > --

[jira] [Updated] (KAFKA-8331) Add system test for enabling static membership on KStream

2019-06-07 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8331: --- Component/s: streams > Add system test for enabling static membership on KStream > --

  1   2   3   4   5   6   7   8   9   >