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

2019-05-17 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8324: --- Labels: kip (was: ) > User constructed RocksObjects leak memory > --

[jira] [Created] (KAFKA-8382) Add TimestampedSessionStore

2019-05-17 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-8382: -- Summary: Add TimestampedSessionStore Key: KAFKA-8382 URL: https://issues.apache.org/jira/browse/KAFKA-8382 Project: Kafka Issue Type: New Feature

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

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

[jira] [Commented] (KAFKA-8315) Historical join issues

2019-05-17 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16842568#comment-16842568 ] Matthias J. Sax commented on KAFKA-8315: Agreed. As mentioned above:  https://iss

[jira] [Resolved] (KAFKA-6455) Improve timestamp propagation at DSL level

2019-05-18 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6455. Resolution: Fixed Fix Version/s: 2.3.0 > Improve timestamp propagation at DSL level

[jira] [Commented] (KAFKA-8388) Add methods to query for entries in KTable using timestamp

2019-05-18 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16843159#comment-16843159 ] Matthias J. Sax commented on KAFKA-8388: Thanks for creating this ticket. {quote}

[jira] [Commented] (KAFKA-8388) Add methods to query for entries in KTable using timestamp

2019-05-18 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16843221#comment-16843221 ] Matthias J. Sax commented on KAFKA-8388: Just to clarify: this ticket is not abou

[jira] [Commented] (KAFKA-8388) Add methods to query for entries in KTable using timestamp

2019-05-19 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16843394#comment-16843394 ] Matthias J. Sax commented on KAFKA-8388: I was thinking about TTL, because the ti

[jira] [Commented] (KAFKA-7994) Improve Stream-Time for rebalances and restarts

2019-05-19 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16843402#comment-16843402 ] Matthias J. Sax commented on KAFKA-7994: Adding partition time to the context mig

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

2019-05-19 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16843405#comment-16843405 ] Matthias J. Sax commented on KAFKA-8347: I think, the cherry pick happened after

[jira] [Created] (KAFKA-8391) Flaky Test RebalanceSourceConnectorsIntegrationTest#testDeleteConnector

2019-05-19 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-8391: -- Summary: Flaky Test RebalanceSourceConnectorsIntegrationTest#testDeleteConnector Key: KAFKA-8391 URL: https://issues.apache.org/jira/browse/KAFKA-8391 Project: Ka

[jira] [Commented] (KAFKA-7647) Flaky test LogCleanerParameterizedIntegrationTest.testCleansCombinedCompactAndDeleteTopic

2019-05-19 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16843411#comment-16843411 ] Matthias J. Sax commented on KAFKA-7647: Failed again:  [https://builds.apache.or

[jira] [Commented] (KAFKA-7994) Improve Stream-Time for rebalances and restarts

2019-05-19 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16843517#comment-16843517 ] Matthias J. Sax commented on KAFKA-7994: > So this might handle how partition tim

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

2019-05-20 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16843733#comment-16843733 ] Matthias J. Sax commented on KAFKA-8207: I think that's correct. [~bchen225242] w

[jira] [Commented] (KAFKA-7994) Improve Stream-Time for rebalances and restarts

2019-05-20 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16843739#comment-16843739 ] Matthias J. Sax commented on KAFKA-7994: I am personally not convinced, that usin

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

2019-05-20 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16844062#comment-16844062 ] Matthias J. Sax commented on KAFKA-8207: I actually just talked to [~bchen225242]

[jira] [Updated] (KAFKA-8396) Clean up Transformer API

2019-05-20 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8396: --- Labels: needs-kip (was: ) > Clean up Transformer API > > >

[jira] [Resolved] (KAFKA-7358) Alternative Partitioner to Support "Always Round-Robin" Selection

2019-05-20 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7358. Resolution: Duplicate > Alternative Partitioner to Support "Always Round-Robin" Selection >

[jira] [Commented] (KAFKA-7991) Add StreamsUpgradeTest for 2.2 release

2019-05-21 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16844670#comment-16844670 ] Matthias J. Sax commented on KAFKA-7991: [~vvcephei] Seems this overlaps with  ht

[jira] [Commented] (KAFKA-7245) Deprecate WindowStore#put(key, value)

2019-05-21 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16845126#comment-16845126 ] Matthias J. Sax commented on KAFKA-7245: Well. [~panuwat.anawatmongk...@gmail.com

[jira] [Commented] (KAFKA-7245) Deprecate WindowStore#put(key, value)

2019-05-21 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16845161#comment-16845161 ] Matthias J. Sax commented on KAFKA-7245: No problem [~panuwat.anawatmongk...@gmai

[jira] [Commented] (KAFKA-7245) Deprecate WindowStore#put(key, value)

2019-05-22 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16845782#comment-16845782 ] Matthias J. Sax commented on KAFKA-7245: Well. First we need a KIP to deprecate t

[jira] [Commented] (KAFKA-7245) Deprecate WindowStore#put(key, value)

2019-05-22 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16846416#comment-16846416 ] Matthias J. Sax commented on KAFKA-7245: All public API changes need a KIP. Hence

[jira] [Commented] (KAFKA-7928) Deprecate WindowStore.put(key, value)

2019-05-22 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16846417#comment-16846417 ] Matthias J. Sax commented on KAFKA-7928: This sees to be a duplicate of https://i

[jira] [Commented] (KAFKA-8411) Option to keep tombstones forever in compacted logs

2019-05-23 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16846775#comment-16846775 ] Matthias J. Sax commented on KAFKA-8411: Well. The config is of type long. If you

[jira] [Updated] (KAFKA-8411) Option to keep tombstones forever in compacted logs

2019-05-23 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8411: --- Priority: Minor (was: Major) > Option to keep tombstones forever in compacted logs > --

[jira] [Commented] (KAFKA-8412) Still a nullpointer exception thrown on shutdown while flushing before closing producers

2019-05-23 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16846787#comment-16846787 ] Matthias J. Sax commented on KAFKA-8412: Thanks for reporting this. What I don't

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

2019-05-23 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16846791#comment-16846791 ] Matthias J. Sax commented on KAFKA-8413: This should already be fixed. You need t

[jira] [Commented] (KAFKA-7245) Deprecate WindowStore#put(key, value)

2019-05-23 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16846800#comment-16846800 ] Matthias J. Sax commented on KAFKA-7245: Yes. The classes you listed _implement_

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

2019-05-23 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16846844#comment-16846844 ] Matthias J. Sax commented on KAFKA-8413: {quote}I've enabled topology optimizatio

[jira] [Commented] (KAFKA-8412) Still a nullpointer exception thrown on shutdown while flushing before closing producers

2019-05-23 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16846851#comment-16846851 ] Matthias J. Sax commented on KAFKA-8412: Do you run with EOS enabled? Also, clos

[jira] [Commented] (KAFKA-7994) Improve Stream-Time for rebalances and restarts

2019-05-23 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16846857#comment-16846857 ] Matthias J. Sax commented on KAFKA-7994: I think it might actually be worth to sp

[jira] [Created] (KAFKA-8423) Update ducktape to not use deprecated APIs

2019-05-23 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-8423: -- Summary: Update ducktape to not use deprecated APIs Key: KAFKA-8423 URL: https://issues.apache.org/jira/browse/KAFKA-8423 Project: Kafka Issue Type: Impr

[jira] [Commented] (KAFKA-8423) Update ducktape to not use deprecated APIs

2019-05-24 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16847786#comment-16847786 ] Matthias J. Sax commented on KAFKA-8423: Sure. I added you to the list on contrib

[jira] [Assigned] (KAFKA-8412) Still a nullpointer exception thrown on shutdown while flushing before closing producers

2019-05-24 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-8412: -- Assignee: Matthias J. Sax > Still a nullpointer exception thrown on shutdown while flu

[jira] [Commented] (KAFKA-7540) Flaky Test ConsumerBounceTest#testClose

2019-05-24 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16847825#comment-16847825 ] Matthias J. Sax commented on KAFKA-7540: One more:  [https://builds.apache.org/jo

[jira] [Commented] (KAFKA-7245) Deprecate WindowStore#put(key, value)

2019-05-25 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16848301#comment-16848301 ] Matthias J. Sax commented on KAFKA-7245: [~omanges]: KIPs are discussed on the de

[jira] [Commented] (KAFKA-7245) Deprecate WindowStore#put(key, value)

2019-05-25 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16848302#comment-16848302 ] Matthias J. Sax commented on KAFKA-7245: Please also update  [https://cwiki.apach

[jira] [Commented] (KAFKA-8433) Give the opportunity to use serializers and deserializers with IntegrationTestUtils

2019-05-26 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16848605#comment-16848605 ] Matthias J. Sax commented on KAFKA-8433: I seems you are using this class for you

[jira] [Commented] (KAFKA-7994) Improve Stream-Time for rebalances and restarts

2019-05-26 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16848607#comment-16848607 ] Matthias J. Sax commented on KAFKA-7994: Yes. Please rebase the PR to only includ

[jira] [Commented] (KAFKA-8433) Give the opportunity to use serializers and deserializers with IntegrationTestUtils

2019-05-28 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16849911#comment-16849911 ] Matthias J. Sax commented on KAFKA-8433: \cc [~guozhang] [~bbejeck] WDYT? > Give

[jira] [Updated] (KAFKA-8446) KStream restoration will crash with NPE when the record value is null

2019-05-29 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8446: --- Component/s: streams > KStream restoration will crash with NPE when the record value is null

[jira] [Commented] (KAFKA-8377) KTable#transformValue might lead to incorrect result in joins

2019-05-30 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16852453#comment-16852453 ] Matthias J. Sax commented on KAFKA-8377: If we decide to materialize the upstream

[jira] [Updated] (KAFKA-8446) Kafka Streams restoration crashes with NPE when the record value is null

2019-05-30 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8446: --- Summary: Kafka Streams restoration crashes with NPE when the record value is null (was: KStr

[jira] [Commented] (KAFKA-8377) KTable#transformValue might lead to incorrect result in joins

2019-05-30 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16852686#comment-16852686 ] Matthias J. Sax commented on KAFKA-8377: Not sure if I can follow. The decision t

[jira] [Updated] (KAFKA-8456) Flaky Test StoreUpgradeIntegrationTest#shouldMigratePersistentWindowStoreToTimestampedWindowStoreUsingPapi

2019-05-31 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8456: --- Component/s: unit tests > Flaky Test > StoreUpgradeIntegrationTest#shouldMigratePersistentW

[jira] [Updated] (KAFKA-8454) Add Java AdminClient interface

2019-05-31 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8454: --- Component/s: (was: streams) (was: core) > Add Java AdminClient inter

[jira] [Commented] (KAFKA-8377) KTable#transformValue might lead to incorrect result in joins

2019-05-31 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16853386#comment-16853386 ] Matthias J. Sax commented on KAFKA-8377: Cool. [~Yohan123] – let us know if you

[jira] [Commented] (KAFKA-7994) Improve Stream-Time for rebalances and restarts

2019-05-31 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16853388#comment-16853388 ] Matthias J. Sax commented on KAFKA-7994: Well. `suppress()` in not "affected" bec

[jira] [Updated] (KAFKA-8455) Add NothingSerde to Serdes

2019-05-31 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8455: --- Labels: beginner needs-kip newbie newbie++ (was: ) > Add NothingSerde to Serdes > --

[jira] [Updated] (KAFKA-8260) Flaky test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

2019-05-31 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8260: --- Affects Version/s: 2.2.0 > Flaky test > ConsumerBounceTest#testRollingBrokerRestartsWithSmal

[jira] [Commented] (KAFKA-8260) Flaky test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

2019-05-31 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16853401#comment-16853401 ] Matthias J. Sax commented on KAFKA-8260: Saw this test failing locally (2.2 branc

[jira] [Created] (KAFKA-8458) Flaky Test AdminClientIntegrationTest#testElectPreferredLeaders

2019-05-31 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-8458: -- Summary: Flaky Test AdminClientIntegrationTest#testElectPreferredLeaders Key: KAFKA-8458 URL: https://issues.apache.org/jira/browse/KAFKA-8458 Project: Kafka

[jira] [Assigned] (KAFKA-7315) Streams serialization docs contain a broken link for Avro

2019-06-01 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-7315: -- Assignee: Victoria Bialas > Streams serialization docs contain a broken link for Avro

[jira] [Commented] (KAFKA-7315) Streams serialization docs contain a broken link for Avro

2019-06-01 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16853832#comment-16853832 ] Matthias J. Sax commented on KAFKA-7315: [~orangesnap] Assigned this ticket to yo

[jira] [Commented] (KAFKA-8272) Changed(De)Serializer does not forward configure() call

2019-06-03 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16855090#comment-16855090 ] Matthias J. Sax commented on KAFKA-8272: No. Removed fixed version. We can set if

[jira] [Updated] (KAFKA-8272) Changed(De)Serializer does not forward configure() call

2019-06-03 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8272: --- Fix Version/s: (was: 2.3.0) > Changed(De)Serializer does not forward configure() call > -

[jira] [Updated] (KAFKA-8155) Update Streams system tests for 2.2.0 and 2.1.1 releases

2019-06-03 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8155: --- Priority: Blocker (was: Major) > Update Streams system tests for 2.2.0 and 2.1.1 releases >

[jira] [Updated] (KAFKA-8446) Kafka Streams restoration crashes with NPE when the record value is null

2019-06-03 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8446: --- Fix Version/s: 2.3.0 > Kafka Streams restoration crashes with NPE when the record value is nu

[jira] [Commented] (KAFKA-8433) Give the opportunity to use serializers and deserializers with IntegrationTestUtils

2019-06-03 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16855305#comment-16855305 ] Matthias J. Sax commented on KAFKA-8433: A [~callaertanthony] – does using the pu

[jira] [Commented] (KAFKA-7578) Kafka streams: add possibility to choose multiple output topics

2019-06-03 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16855347#comment-16855347 ] Matthias J. Sax commented on KAFKA-7578: [~tdanylchuk] Was wondering about this t

[jira] [Commented] (KAFKA-8455) Add NothingSerde to Serdes

2019-06-04 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16855963#comment-16855963 ] Matthias J. Sax commented on KAFKA-8455: [~suryateja...@gmail.com] seems that [~c

[jira] [Commented] (KAFKA-8455) Add NothingSerde to Serdes

2019-06-04 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16856171#comment-16856171 ] Matthias J. Sax commented on KAFKA-8455: Thanks [~cemozen]. [~suryateja...@gmail

[jira] [Commented] (KAFKA-8486) How to commit offset via Kafka

2019-06-05 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16856952#comment-16856952 ] Matthias J. Sax commented on KAFKA-8486: Please ask questions on the user mailing

[jira] [Resolved] (KAFKA-8486) How to commit offset via Kafka

2019-06-05 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-8486. Resolution: Invalid > How to commit offset via Kafka > --- > >

[jira] [Commented] (KAFKA-8433) Give the opportunity to use serializers and deserializers with IntegrationTestUtils

2019-06-05 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16857032#comment-16857032 ] Matthias J. Sax commented on KAFKA-8433: Thanks for the feedback [~callaertanthon

[jira] [Updated] (KAFKA-8501) Remove key and value from exception message

2019-06-06 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8501: --- Labels: easy-fix newbie (was: ) > Remove key and value from exception message >

[jira] [Updated] (KAFKA-8501) Remove key and value from exception message

2019-06-06 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8501: --- Issue Type: Improvement (was: Bug) > Remove key and value from exception message > -

[jira] [Updated] (KAFKA-8501) Remove key and value from exception message

2019-06-06 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8501: --- Component/s: streams > Remove key and value from exception message >

[jira] [Commented] (KAFKA-8504) Suppressed do not emit with TimeWindows

2019-06-08 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16859341#comment-16859341 ] Matthias J. Sax commented on KAFKA-8504: While I agree, that it would be better t

[jira] [Updated] (KAFKA-8504) Suppressed do not emit with TimeWindows

2019-06-08 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8504: --- Issue Type: Improvement (was: Bug) > Suppressed do not emit with TimeWindows > -

[jira] [Updated] (KAFKA-8504) Suppressed do not emit with TimeWindows

2019-06-08 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8504: --- Component/s: documentation > Suppressed do not emit with TimeWindows > --

[jira] [Comment Edited] (KAFKA-8504) Suppressed do not emit with TimeWindows

2019-06-08 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16859341#comment-16859341 ] Matthias J. Sax edited comment on KAFKA-8504 at 6/9/19 1:51 AM: ---

[jira] [Updated] (KAFKA-8510) Update StreamsPartitionAssignor to use the built-in owned partitions to achieve stickiness (part 7)

2019-06-08 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8510: --- Component/s: streams > Update StreamsPartitionAssignor to use the built-in owned partitions t

[jira] [Updated] (KAFKA-8513) Add kafka-streams-application-reset.bat for Windows platform

2019-06-08 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8513: --- Component/s: streams > Add kafka-streams-application-reset.bat for Windows platform > ---

[jira] [Commented] (KAFKA-8513) Add kafka-streams-application-reset.bat for Windows platform

2019-06-08 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16859343#comment-16859343 ] Matthias J. Sax commented on KAFKA-8513: Thanks for the ticket and the PR [~sekik

[jira] [Commented] (KAFKA-7911) Add Timezone Support for Windowed Aggregations

2019-06-08 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16859369#comment-16859369 ] Matthias J. Sax commented on KAFKA-7911: Passing in a different `TimeWindow` seem

[jira] [Updated] (KAFKA-8515) Materialize KTable when upstream uses Windowed instead of

2019-06-09 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8515: --- Component/s: streams > Materialize KTable when upstream uses Windowed instead of > -

[jira] [Updated] (KAFKA-8504) Suppressed do not emit with TimeWindows

2019-06-10 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8504: --- Labels: newbie (was: ) > Suppressed do not emit with TimeWindows > -

[jira] [Updated] (KAFKA-8504) Update Docs to explain how to use suppress() in more details

2019-06-10 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8504: --- Summary: Update Docs to explain how to use suppress() in more details (was: Suppressed do no

[jira] [Resolved] (KAFKA-7315) Streams serialization docs contain a broken link for Avro

2019-06-10 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7315. Resolution: Fixed > Streams serialization docs contain a broken link for Avro > ---

[jira] [Commented] (KAFKA-8516) Consider allowing all replicas to have read/write permissions

2019-06-10 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16860225#comment-16860225 ] Matthias J. Sax commented on KAFKA-8516: [~Yohan123] Are you aware of  [https://c

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

2019-06-10 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16860318#comment-16860318 ] Matthias J. Sax commented on KAFKA-7937: Another failure in trunk:  [https://buil

[jira] [Commented] (KAFKA-8516) Consider allowing all replicas to have read/write permissions

2019-06-10 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16860587#comment-16860587 ] Matthias J. Sax commented on KAFKA-8516: Agreed. In fact, I am not even sure if

[jira] [Commented] (KAFKA-8513) Add kafka-streams-application-reset.bat for Windows platform

2019-06-10 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16860588#comment-16860588 ] Matthias J. Sax commented on KAFKA-8513: Ack. Fine with me. The PR looks good in

[jira] [Commented] (KAFKA-8450) Augment processed in MockProcessor as KeyValueAndTimestamp

2019-06-10 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16860589#comment-16860589 ] Matthias J. Sax commented on KAFKA-8450: Yes. Instead of calling `makeRecord` tha

[jira] [Commented] (KAFKA-8041) Flaky Test LogDirFailureTest#testIOExceptionDuringLogRoll

2019-06-10 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16860594#comment-16860594 ] Matthias J. Sax commented on KAFKA-8041: Failed again:  [https://builds.apache.or

[jira] [Commented] (KAFKA-8078) Flaky Test TableTableJoinIntegrationTest#testInnerInner

2019-06-10 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16860596#comment-16860596 ] Matthias J. Sax commented on KAFKA-8078: Failed again with timeout:  [https://bui

[jira] [Updated] (KAFKA-7988) Flaky Test DynamicBrokerReconfigurationTest#testThreadPoolResize

2019-06-10 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7988: --- Affects Version/s: 2.3.0 > Flaky Test DynamicBrokerReconfigurationTest#testThreadPoolResize >

[jira] [Commented] (KAFKA-7988) Flaky Test DynamicBrokerReconfigurationTest#testThreadPoolResize

2019-06-10 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16860597#comment-16860597 ] Matthias J. Sax commented on KAFKA-7988: Failed in 2.3:  [https://builds.apache.o

[jira] [Updated] (KAFKA-8418) Connect System tests are not waiting for REST resources to be registered

2019-06-10 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8418: --- Fix Version/s: (was: 2.3) > Connect System tests are not waiting for REST resources to be

[jira] [Updated] (KAFKA-8265) Connect Client Config Override policy

2019-06-10 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8265: --- Fix Version/s: (was: 2.3) 2.3.0 > Connect Client Config Override polic

[jira] [Updated] (KAFKA-8473) Adjust Connect system tests for incremental cooperative rebalancing and enable them for both eager and incremental cooperative rebalancing

2019-06-10 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8473: --- Affects Version/s: (was: 2.3) 2.3.0 > Adjust Connect system tests

[jira] [Updated] (KAFKA-8475) Temporarily restore SslFactory.sslContext() helper

2019-06-10 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8475: --- Fix Version/s: (was: 2.3) 2.3.0 > Temporarily restore SslFactory.sslCo

[jira] [Updated] (KAFKA-8473) Adjust Connect system tests for incremental cooperative rebalancing and enable them for both eager and incremental cooperative rebalancing

2019-06-10 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8473: --- Fix Version/s: (was: 2.3) 2.3.0 > Adjust Connect system tests for incr

[jira] [Commented] (KAFKA-8263) Flaky Test MetricsIntegrationTest#testStreamMetricOfWindowStore

2019-06-10 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16860599#comment-16860599 ] Matthias J. Sax commented on KAFKA-8263: [https://builds.apache.org/blue/organiza

[jira] [Resolved] (KAFKA-8193) Flaky Test MetricsIntegrationTest#testStreamMetricOfWindowStore

2019-06-10 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-8193. Resolution: Duplicate > Flaky Test MetricsIntegrationTest#testStreamMetricOfWindowStore > -

[jira] [Updated] (KAFKA-8193) Flaky Test MetricsIntegrationTest#testStreamMetricOfWindowStore

2019-06-10 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8193: --- Fix Version/s: (was: 2.4.0) > Flaky Test MetricsIntegrationTest#testStreamMetricOfWindowS

[jira] [Commented] (KAFKA-8456) Flaky Test StoreUpgradeIntegrationTest#shouldMigratePersistentWindowStoreToTimestampedWindowStoreUsingPapi

2019-06-11 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16861337#comment-16861337 ] Matthias J. Sax commented on KAFKA-8456: One more:  [https://builds.apache.org/bl

[jira] [Updated] (KAFKA-8305) AdminClient should support creating topics with default partitions and replication factor

2019-06-11 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8305: --- Labels: kip (was: ) > AdminClient should support creating topics with default partitions and

<    1   2   3   4   5   6   7   8   9   10   >