[jira] [Assigned] (KAFKA-10036) Improve error message if user violates `Supplier` pattern

2020-08-03 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-10036: --- Assignee: Igor Soarez (was: Alex Sun) > Improve error message if user violates `Su

[jira] [Commented] (KAFKA-10036) Improve error message if user violates `Supplier` pattern

2020-08-03 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17170493#comment-17170493 ] Matthias J. Sax commented on KAFKA-10036: - [~soarez] – in general, before you ta

[jira] [Updated] (KAFKA-10351) Add missing tests for IOExceptions for GlobalStateManagerImpl

2020-08-03 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-10351: Issue Type: Test (was: Improvement) > Add missing tests for IOExceptions for GlobalStateM

[jira] [Created] (KAFKA-10351) Add missing tests for IOExceptions for GlobalStateManagerImpl

2020-08-03 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-10351: --- Summary: Add missing tests for IOExceptions for GlobalStateManagerImpl Key: KAFKA-10351 URL: https://issues.apache.org/jira/browse/KAFKA-10351 Project: Kafka

[jira] [Updated] (KAFKA-10316) Consider renaming getter method for Interactive Queries

2020-08-04 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-10316: Description: In the 2.5 release, we introduce new classes for Interactive Queries via KIP

[jira] [Updated] (KAFKA-10316) Consider renaming getter method for Interactive Queries

2020-08-04 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-10316: Labels: beginner kip newbie (was: beginner need-kip newbie) > Consider renaming getter me

[jira] [Updated] (KAFKA-10316) Consider renaming getter method for Interactive Queries

2020-08-04 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-10316: Description: In the 2.5 release, we introduce new classes for Interactive Queries via KIP

[jira] [Commented] (KAFKA-4587) Rethink Unification of Caching with Dedupping

2020-08-04 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-4587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17171088#comment-17171088 ] Matthias J. Sax commented on KAFKA-4587: In general yes, I guess. Why? > Rethink

[jira] [Commented] (KAFKA-10357) Handle accidental deletion of repartition-topics as exceptional failure

2020-08-04 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17171090#comment-17171090 ] Matthias J. Sax commented on KAFKA-10357: - How would this work with regard to th

[jira] [Assigned] (KAFKA-10186) Aborting transaction with pending data should throw non-fatal exception

2020-08-04 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-10186: --- Assignee: Gokul Srinivas > Aborting transaction with pending data should throw non-

[jira] [Commented] (KAFKA-10186) Aborting transaction with pending data should throw non-fatal exception

2020-08-04 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17171092#comment-17171092 ] Matthias J. Sax commented on KAFKA-10186: - [~nym3r0s] I added you to the list on

[jira] [Updated] (KAFKA-9302) Allow custom partitioning in table-table joins

2020-08-04 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9302: --- Description: For KTables, Kafka Streams assume that both input tables are partitions by thei

[jira] [Updated] (KAFKA-10369) Introduce Distinct operation in KStream

2020-08-06 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-10369: Component/s: streams > Introduce Distinct operation in KStream > -

[jira] [Updated] (KAFKA-10369) Introduce Distinct operation in KStream

2020-08-06 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-10369: Labels: kip (was: ) > Introduce Distinct operation in KStream > -

[jira] [Commented] (KAFKA-10380) Make dist flatten rocksdbjni

2020-08-19 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17180878#comment-17180878 ] Matthias J. Sax commented on KAFKA-10380: - [~adriancole] – when you say "Kafka i

[jira] [Commented] (KAFKA-10395) TopologyTestDriver does not work with dynamic topic routing

2020-08-19 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17180881#comment-17180881 ] Matthias J. Sax commented on KAFKA-10395: - [~ableegoldman] [~vvcephei] Seems the

[jira] [Assigned] (KAFKA-10396) Overall memory of container keep on growing due to kafka stream / rocksdb and OOM killed once limit reached

2020-08-19 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-10396: --- Assignee: Rohan Desai > Overall memory of container keep on growing due to kafka st

[jira] [Updated] (KAFKA-10408) Calendar based windows

2020-08-19 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-10408: Labels: needs-kip (was: ) > Calendar based windows > -- > >

[jira] [Commented] (KAFKA-10408) Calendar based windows

2020-08-19 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17180882#comment-17180882 ] Matthias J. Sax commented on KAFKA-10408: - Another example implementation is thi

[jira] [Issue Comment Deleted] (KAFKA-10395) TopologyTestDriver does not work with dynamic topic routing

2020-08-19 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-10395: Comment: was deleted (was: [~ableegoldman] [~vvcephei] Seems the PR was merged. Can we clo

[jira] [Assigned] (KAFKA-8812) Rebalance Producers

2020-08-19 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-8812: -- Assignee: (was: Matthias J. Sax) > Rebalance Producers > --- > >

[jira] [Commented] (KAFKA-10380) Make dist flatten rocksdbjni

2020-08-19 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17180889#comment-17180889 ] Matthias J. Sax commented on KAFKA-10380: - Thanks for clarifying. I am sure that

[jira] [Commented] (KAFKA-10186) Aborting transaction with pending data should throw non-fatal exception

2020-08-21 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17182086#comment-17182086 ] Matthias J. Sax commented on KAFKA-10186: - Thanks [~nym3r0s] – working on the co

[jira] [Commented] (KAFKA-10434) Remove deprecated methods on WindowStore

2020-08-25 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17184776#comment-17184776 ] Matthias J. Sax commented on KAFKA-10434: - We want to keep those methods as disc

[jira] [Updated] (KAFKA-10395) TopologyTestDriver does not work with dynamic topic routing

2020-08-26 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-10395: Fix Version/s: 2.6.1 > TopologyTestDriver does not work with dynamic topic routing > -

[jira] [Commented] (KAFKA-10366) TimeWindowedDeserializer doesn't allow users to set a custom window size

2020-08-27 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17186265#comment-17186265 ] Matthias J. Sax commented on KAFKA-10366: - Following [~ableegoldman] last commen

[jira] [Updated] (KAFKA-10445) Align IQ SessionStore API with Instant-based methods as ReadOnlyWindowStore

2020-08-28 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-10445: Labels: needs-kip (was: ) > Align IQ SessionStore API with Instant-based methods as ReadO

[jira] [Updated] (KAFKA-10445) Align IQ SessionStore API with Instant-based methods as ReadOnlyWindowStore

2020-08-28 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-10445: Labels: beginner needs-kip newbie (was: needs-kip) > Align IQ SessionStore API with Insta

[jira] [Updated] (KAFKA-10448) Preserve Source Partition in Kafka Streams from context

2020-08-31 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-10448: Labels: needs-kip (was: ) > Preserve Source Partition in Kafka Streams from context > ---

[jira] [Updated] (KAFKA-10448) Preserve Source Partition in Kafka Streams from context

2020-08-31 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-10448: Priority: Minor (was: Critical) > Preserve Source Partition in Kafka Streams from context

[jira] [Updated] (KAFKA-9649) Remove/Warn on use of TimeWindowedSerde with no specified window size

2020-08-31 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9649: --- Labels: kip (was: ) > Remove/Warn on use of TimeWindowedSerde with no specified window size

[jira] [Assigned] (KAFKA-9649) Remove/Warn on use of TimeWindowedSerde with no specified window size

2020-08-31 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-9649: -- Assignee: Leah Thomas > Remove/Warn on use of TimeWindowedSerde with no specified wind

[jira] [Commented] (KAFKA-10362) When resuming Streams active task with EOS, the checkpoint file should be deleted

2020-09-02 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17189711#comment-17189711 ] Matthias J. Sax commented on KAFKA-10362: - [~DOJI], even if the ticket was not a

[jira] [Comment Edited] (KAFKA-10366) TimeWindowedDeserializer doesn't allow users to set a custom window size

2020-09-02 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17189725#comment-17189725 ] Matthias J. Sax edited comment on KAFKA-10366 at 9/2/20, 9:58 PM:

[jira] [Commented] (KAFKA-10366) TimeWindowedDeserializer doesn't allow users to set a custom window size

2020-09-02 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17189725#comment-17189725 ] Matthias J. Sax commented on KAFKA-10366: - SGTM. And no worries about naming. It

[jira] [Commented] (KAFKA-10448) Preserve Source Partition in Kafka Streams from context

2020-09-02 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17189767#comment-17189767 ] Matthias J. Sax commented on KAFKA-10448: - Just added you to the wiki. {quote}Ne

[jira] [Commented] (KAFKA-10362) When resuming Streams active task with EOS, the checkpoint file should be deleted

2020-09-03 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17190178#comment-17190178 ] Matthias J. Sax commented on KAFKA-10362: - Thanks [~DOJI] and [~ipasynkov]! We s

[jira] [Commented] (KAFKA-10448) Preserve Source Partition in Kafka Streams from context

2020-09-08 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17192491#comment-17192491 ] Matthias J. Sax commented on KAFKA-10448: - Thanks, feel free to start a discussi

[jira] [Comment Edited] (KAFKA-9584) Removing headers causes ConcurrentModificationException

2020-09-10 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17059076#comment-17059076 ] Matthias J. Sax edited comment on KAFKA-9584 at 9/10/20, 4:10 PM: -

[jira] [Assigned] (KAFKA-9584) Removing headers causes ConcurrentModificationException

2020-09-10 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-9584: -- Assignee: Micah Ramos > Removing headers causes ConcurrentModificationException >

[jira] [Commented] (KAFKA-6127) Streams should never block infinitely

2020-09-11 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17194548#comment-17194548 ] Matthias J. Sax commented on KAFKA-6127: Not 100% sure either :) – this ticket is

[jira] [Updated] (KAFKA-10481) Consider Improving the Success Criteria of Streams' System Test StreamsBrokerBounceTest

2020-09-16 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-10481: Component/s: system tests > Consider Improving the Success Criteria of Streams' System Tes

[jira] [Commented] (KAFKA-10480) Kafka streams application is being stuck

2020-09-18 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17198533#comment-17198533 ] Matthias J. Sax commented on KAFKA-10480: - What configs do you use for both para

[jira] [Commented] (KAFKA-10493) Ktable out-of-order updates are not being ignored

2020-09-18 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17198538#comment-17198538 ] Matthias J. Sax commented on KAFKA-10493: - Not sure if I fully understand (but t

[jira] [Reopened] (KAFKA-10480) Kafka streams application is being stuck

2020-09-18 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-10480: - > Kafka streams application is being stuck > > >

[jira] [Resolved] (KAFKA-10480) Kafka streams application is being stuck

2020-09-18 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-10480. - Resolution: Invalid > Kafka streams application is being stuck > ---

[jira] [Commented] (KAFKA-10493) Ktable out-of-order updates are not being ignored

2020-09-18 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17198661#comment-17198661 ] Matthias J. Sax commented on KAFKA-10493: - Maybe [~vvcephei] can shed some light

[jira] [Comment Edited] (KAFKA-10493) Ktable out-of-order updates are not being ignored

2020-09-18 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17198661#comment-17198661 ] Matthias J. Sax edited comment on KAFKA-10493 at 9/19/20, 5:48 AM: ---

[jira] [Updated] (KAFKA-10505) [SystemTests] streams_static_membership.py and streams_upgradet_test.py fails

2020-09-21 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-10505: Component/s: system tests streams > [SystemTests] streams_static_membersh

[jira] [Commented] (KAFKA-9075) Extend documentation for usage of GlobalKTable vs KTable

2020-09-21 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17199589#comment-17199589 ] Matthias J. Sax commented on KAFKA-9075: [~high.lee] Are you still interested? Se

[jira] [Commented] (KAFKA-10493) Ktable out-of-order updates are not being ignored

2020-09-21 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17199724#comment-17199724 ] Matthias J. Sax commented on KAFKA-10493: - I have concerns about making it optio

[jira] [Resolved] (KAFKA-10297) Don't use deprecated producer config `retries`

2020-09-23 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-10297. - Resolution: Invalid We change the KIP to not deprecate `retries`. Hence, this ticket is

[jira] [Commented] (KAFKA-9075) Extend documentation for usage of GlobalKTable vs KTable

2020-09-24 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17201617#comment-17201617 ] Matthias J. Sax commented on KAFKA-9075: Well, there is a small mentioning of Glo

[jira] [Updated] (KAFKA-10530) kafka-streams-application-reset misses some internal topics

2020-09-30 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-10530: Component/s: tools > kafka-streams-application-reset misses some internal topics > ---

[jira] [Created] (KAFKA-10555) Improve client state machine

2020-09-30 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-10555: --- Summary: Improve client state machine Key: KAFKA-10555 URL: https://issues.apache.org/jira/browse/KAFKA-10555 Project: Kafka Issue Type: Improvement

[jira] [Resolved] (KAFKA-6585) Consolidate duplicated logic on reset tools

2020-09-30 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6585. Fix Version/s: 2.7.0 Resolution: Fixed > Consolidate duplicated logic on reset tools

[jira] [Assigned] (KAFKA-10503) MockProducer doesn't throw ClassCastException when no partition for topic

2020-09-30 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-10503: --- Assignee: Gonzalo Muñoz Fernández > MockProducer doesn't throw ClassCastException w

[jira] [Commented] (KAFKA-10503) MockProducer doesn't throw ClassCastException when no partition for topic

2020-09-30 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17204946#comment-17204946 ] Matthias J. Sax commented on KAFKA-10503: - I added you to the list of contributo

[jira] [Updated] (KAFKA-10564) Continuous logging about deleting obsolete state directories

2020-10-02 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-10564: Labels: beginner newbie (was: ) > Continuous logging about deleting obsolete state direct

[jira] [Commented] (KAFKA-10569) Running aggregate queries on KSQL client side is getting to ERROR Shutdown broker because all log dirs in ...

2020-10-02 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17206536#comment-17206536 ] Matthias J. Sax commented on KAFKA-10569: - [~petregor...@gmail.com] – ksqlDB is

[jira] [Resolved] (KAFKA-10569) Running aggregate queries on KSQL client side is getting to ERROR Shutdown broker because all log dirs in ...

2020-10-03 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-10569. - Resolution: Invalid > Running aggregate queries on KSQL client side is getting to ERROR

[jira] [Commented] (KAFKA-10569) Running aggregate queries on KSQL client side is getting to ERROR Shutdown broker because all log dirs in ...

2020-10-03 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17206860#comment-17206860 ] Matthias J. Sax commented on KAFKA-10569: - Thanks for chiming in [~agavra]! > R

[jira] [Commented] (KAFKA-10555) Improve client state machine

2020-10-05 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17208492#comment-17208492 ] Matthias J. Sax commented on KAFKA-10555: - {quote}I thought we were only conside

[jira] [Updated] (KAFKA-10577) StreamThread should be able to process any processible tasks regardless of its state

2020-10-05 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-10577: Component/s: streams > StreamThread should be able to process any processible tasks regard

[jira] [Updated] (KAFKA-10578) KIP-675: Convert KTable to a KStream using the previous value

2020-10-06 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-10578: Labels: kip (was: ) > KIP-675: Convert KTable to a KStream using the previous value > ---

[jira] [Updated] (KAFKA-10578) Convert KTable to a KStream using the previous value

2020-10-06 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-10578: Summary: Convert KTable to a KStream using the previous value (was: KIP-675: Convert KTab

[jira] [Updated] (KAFKA-10578) KIP-675: Convert KTable to a KStream using the previous value

2020-10-06 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-10578: Description: Imagine that we have an entity for which we want to emit the difference betwe

[jira] [Commented] (KAFKA-10578) Convert KTable to a KStream using the previous value

2020-10-06 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17209253#comment-17209253 ] Matthias J. Sax commented on KAFKA-10578: - [~javier.freire] – I added you to the

[jira] [Assigned] (KAFKA-10578) Convert KTable to a KStream using the previous value

2020-10-06 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-10578: --- Assignee: Javier Freire Riobó > Convert KTable to a KStream using the previous valu

[jira] [Updated] (KAFKA-10585) Kafka Streams should clean up the state store directory from cleanup

2020-10-08 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-10585: Issue Type: Improvement (was: Bug) > Kafka Streams should clean up the state store direct

[jira] [Updated] (KAFKA-10585) Kafka Streams should clean up the state store directory from cleanup

2020-10-08 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-10585: Priority: Minor (was: Major) > Kafka Streams should clean up the state store directory fr

[jira] [Commented] (KAFKA-10585) Kafka Streams should clean up the state store directory from cleanup

2020-10-08 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17210386#comment-17210386 ] Matthias J. Sax commented on KAFKA-10585: - [~dongjin] – please assign the ticket

[jira] [Assigned] (KAFKA-7334) Suggest changing config for state.dir in case of FileNotFoundException

2020-10-08 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-7334: -- Assignee: Vladimir > Suggest changing config for state.dir in case of FileNotFoundExce

[jira] [Commented] (KAFKA-7334) Suggest changing config for state.dir in case of FileNotFoundException

2020-10-08 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17210410#comment-17210410 ] Matthias J. Sax commented on KAFKA-7334: [~vladimir_shadrin] I added you to the l

[jira] [Updated] (KAFKA-8589) Flakey test ResetConsumerGroupOffsetTest#testResetOffsetsExistingTopic

2019-07-23 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8589: --- Labels: flaky-test (was: ) > Flakey test ResetConsumerGroupOffsetTest#testResetOffsetsExisti

[jira] [Updated] (KAFKA-8589) Flakey test ResetConsumerGroupOffsetTest#testResetOffsetsExistingTopic

2019-07-23 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8589: --- Component/s: clients admin > Flakey test ResetConsumerGroupOffsetTest#testRe

[jira] [Updated] (KAFKA-8589) Flakey test ResetConsumerGroupOffsetTest#testResetOffsetsExistingTopic

2019-07-23 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8589: --- Component/s: unit tests > Flakey test ResetConsumerGroupOffsetTest#testResetOffsetsExistingTo

[jira] [Commented] (KAFKA-8687) Pass store name when creating a Materialized using with(keySerde, valueSerde)

2019-07-23 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16891210#comment-16891210 ] Matthias J. Sax commented on KAFKA-8687: For this case, Java is not able to resol

[jira] [Commented] (KAFKA-7190) Under low traffic conditions purging repartition topics cause WARN statements about UNKNOWN_PRODUCER_ID

2019-07-23 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16891211#comment-16891211 ] Matthias J. Sax commented on KAFKA-7190: Thanks for your comment [~rocketraman] –

[jira] [Commented] (KAFKA-8675) "Main" consumers are not unsubsribed on KafkaStreams.close()

2019-07-23 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16891213#comment-16891213 ] Matthias J. Sax commented on KAFKA-8675: Calling `Consumer#close()` should be suf

[jira] [Commented] (KAFKA-8671) NullPointerException occurs if topic associated with GlobalKTable changes

2019-07-23 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16891216#comment-16891216 ] Matthias J. Sax commented on KAFKA-8671: No reason. Go ahead :) > NullPointerExc

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

2019-07-23 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16891218#comment-16891218 ] Matthias J. Sax commented on KAFKA-8412: I would rather refactor the code directl

[jira] [Commented] (KAFKA-8574) EOS race condition during task transition leads to LocalStateStore truncation in Kafka Streams 2.0.1

2019-07-23 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16891259#comment-16891259 ] Matthias J. Sax commented on KAFKA-8574: I cannot remember all the details. What

[jira] [Commented] (KAFKA-6793) Unnecessary warning log message

2019-07-23 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16891264#comment-16891264 ] Matthias J. Sax commented on KAFKA-6793: {quote}still happen in 2.2.1 {quote} Wel

[jira] [Resolved] (KAFKA-6708) Review Exception messages with regards to Serde Useage

2019-07-23 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6708. Resolution: Duplicate > Review Exception messages with regards to Serde Useage > --

[jira] [Commented] (KAFKA-8677) Flakey test GroupEndToEndAuthorizationTest#testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl

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

[jira] [Updated] (KAFKA-8677) Flakey test GroupEndToEndAuthorizationTest#testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl

2019-07-23 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8677: --- Affects Version/s: 2.4.0 > Flakey test > GroupEndToEndAuthorizationTest#testNoDescribeProduc

[jira] [Updated] (KAFKA-8677) Flakey test GroupEndToEndAuthorizationTest#testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl

2019-07-23 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8677: --- Component/s: unit tests > Flakey test > GroupEndToEndAuthorizationTest#testNoDescribeProduce

[jira] [Updated] (KAFKA-8677) Flakey test GroupEndToEndAuthorizationTest#testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl

2019-07-23 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8677: --- Component/s: security core > Flakey test > GroupEndToEndAuthorizationTest#t

[jira] [Updated] (KAFKA-8677) Flakey test GroupEndToEndAuthorizationTest#testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl

2019-07-23 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8677: --- Labels: flaky-test (was: ) > Flakey test > GroupEndToEndAuthorizationTest#testNoDescribePro

[jira] [Commented] (KAFKA-8589) Flakey test ResetConsumerGroupOffsetTest#testResetOffsetsExistingTopic

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

[jira] [Updated] (KAFKA-8122) Flaky Test EosIntegrationTest#shouldNotViolateEosIfOneTaskFailsWithState

2019-07-24 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8122: --- Affects Version/s: 2.4.0 > Flaky Test EosIntegrationTest#shouldNotViolateEosIfOneTaskFailsWit

[jira] [Commented] (KAFKA-8122) Flaky Test EosIntegrationTest#shouldNotViolateEosIfOneTaskFailsWithState

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

[jira] [Commented] (KAFKA-7940) Flaky Test CustomQuotaCallbackTest#testCustomQuotaCallback

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

[jira] [Updated] (KAFKA-8712) Build Kafka Streams against Scala 2.13

2019-07-24 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8712: --- Affects Version/s: (was: 2.3.0) > Build Kafka Streams against Scala 2.13 > --

[jira] [Updated] (KAFKA-8712) Build Kafka Streams against Scala 2.13

2019-07-24 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8712: --- Fix Version/s: 2.4.0 > Build Kafka Streams against Scala 2.13 > -

[jira] [Commented] (KAFKA-8712) Build Kafka Streams against Scala 2.13

2019-07-24 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16892260#comment-16892260 ] Matthias J. Sax commented on KAFKA-8712: [~ijuma] Are you saying, that we don't n

[jira] [Commented] (KAFKA-8677) Flakey test GroupEndToEndAuthorizationTest#testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl

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

[jira] [Commented] (KAFKA-8712) Build Kafka Streams against Scala 2.13

2019-07-25 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16893011#comment-16893011 ] Matthias J. Sax commented on KAFKA-8712: [~loicmdivad] Seems this request is alre

[jira] [Resolved] (KAFKA-8712) Build Kafka Streams against Scala 2.13

2019-07-25 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-8712. Resolution: Duplicate Fix Version/s: (was: 2.4.0) > Build Kafka Streams against

<    5   6   7   8   9   10   11   12   13   14   >