[jira] [Assigned] (KAFKA-5697) StreamThread.close() need to interrupt the stream threads to break the loop

[ https://issues.apache.org/jira/browse/KAFKA-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mariam John reassigned KAFKA-5697: -- Assignee: Mariam John > StreamThread.close() need to interrupt the stream threads to break the

[jira] [Assigned] (KAFKA-5581) Streams can be smarter in deciding when to create changelog topics for state stores

[ https://issues.apache.org/jira/browse/KAFKA-5581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mariam John reassigned KAFKA-5581: -- Assignee: Mariam John > Streams can be smarter in deciding when to create changelog topics for

[jira] [Commented] (KAFKA-2111) Command Line Standardization - Add Help Arguments & List Required Fields

[ https://issues.apache.org/jira/browse/KAFKA-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16052033#comment-16052033 ] Mariam John commented on KAFKA-2111: Hi Tom, I am sorry I just saw this message right now. I am

[jira] [Updated] (KAFKA-5697) StreamThread.close() need to interrupt the stream threads to break the loop

[ https://issues.apache.org/jira/browse/KAFKA-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mariam John updated KAFKA-5697: --- Description: In {{StreamThread.close()}} we currently do nothing but set the state, hoping the

[jira] [Assigned] (KAFKA-4994) Fix findbugs warning about OffsetStorageWriter#currentFlushId

[ https://issues.apache.org/jira/browse/KAFKA-4994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mariam John reassigned KAFKA-4994: -- Assignee: (was: Mariam John) > Fix findbugs warning about

[jira] [Assigned] (KAFKA-5697) StreamThread.close() need to interrupt the stream threads to break the loop

[ https://issues.apache.org/jira/browse/KAFKA-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mariam John reassigned KAFKA-5697: -- Assignee: (was: Mariam John) > StreamThread.close() need to interrupt the stream threads

[jira] [Commented] (KAFKA-5697) StreamThread.close() need to interrupt the stream threads to break the loop

[ https://issues.apache.org/jira/browse/KAFKA-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16333410#comment-16333410 ] Mariam John commented on KAFKA-5697: @Guozhang Wang, sorry for the delay in responding. Just saw the

[jira] [Resolved] (KAFKA-4370) CorruptRecordException when ProducerRecord constructed without key nor partition and send

[ https://issues.apache.org/jira/browse/KAFKA-4370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mariam John resolved KAFKA-4370. Resolution: Duplicate Fix Version/s: 1.0.0 This is already fixed in

[jira] [Commented] (KAFKA-4370) CorruptRecordException when ProducerRecord constructed without key nor partition and send

[ https://issues.apache.org/jira/browse/KAFKA-4370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16333414#comment-16333414 ] Mariam John commented on KAFKA-4370: I just verified this and looks like the error message for

[jira] [Assigned] (KAFKA-5085) Add test for rebalance exceptions

[ https://issues.apache.org/jira/browse/KAFKA-5085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mariam John reassigned KAFKA-5085: -- Assignee: (was: Mariam John) > Add test for rebalance exceptions >

[jira] [Assigned] (KAFKA-4650) Improve test coverage org.apache.kafka.streams.kstream.internals

[ https://issues.apache.org/jira/browse/KAFKA-4650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mariam John reassigned KAFKA-4650: -- Assignee: Mariam John > Improve test coverage org.apache.kafka.streams.kstream.internals >

[jira] [Assigned] (KAFKA-2939) Make AbstractConfig.logUnused() tunable for clients

[ https://issues.apache.org/jira/browse/KAFKA-2939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mariam John reassigned KAFKA-2939: -- Assignee: Mariam John > Make AbstractConfig.logUnused() tunable for clients >

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

[ https://issues.apache.org/jira/browse/KAFKA-6708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mariam John reassigned KAFKA-6708: -- Assignee: Mariam John > Review Exception messages with regards to Serde Useage >

[jira] [Resolved] (KAFKA-6720) Inconsistent Kafka Streams behaviour when topic does not exist

[ https://issues.apache.org/jira/browse/KAFKA-6720?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mariam John resolved KAFKA-6720. Resolution: Duplicate This is similar to KAFKA-6437. > Inconsistent Kafka Streams behaviour when

[jira] [Commented] (KAFKA-6720) Inconsistent Kafka Streams behaviour when topic does not exist

[ https://issues.apache.org/jira/browse/KAFKA-6720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16418089#comment-16418089 ] Mariam John commented on KAFKA-6720: [~wojda] if you look at the resolved tag, it is marked as

[jira] [Commented] (KAFKA-6437) Streams does not warn about missing input topics, but hangs

[ https://issues.apache.org/jira/browse/KAFKA-6437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16418185#comment-16418185 ] Mariam John commented on KAFKA-6437: [~mjsax] what do you mean by partially available input topics?

[jira] [Commented] (KAFKA-6437) Streams does not warn about missing input topics, but hangs

[ https://issues.apache.org/jira/browse/KAFKA-6437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16409759#comment-16409759 ] Mariam John commented on KAFKA-6437: In the KafkaStreams we can use the admin client to list all

[jira] [Assigned] (KAFKA-6437) Streams does not warn about missing input topics, but hangs

[ https://issues.apache.org/jira/browse/KAFKA-6437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mariam John reassigned KAFKA-6437: -- Assignee: Mariam John > Streams does not warn about missing input topics, but hangs >

[jira] [Commented] (KAFKA-6437) Streams does not warn about missing input topics, but hangs

[ https://issues.apache.org/jira/browse/KAFKA-6437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16411910#comment-16411910 ] Mariam John commented on KAFKA-6437: I will do that [~mjsax]. I agree that a WARN message seems right

[jira] [Assigned] (KAFKA-7492) Explain `null` handling for reduce and aggregate

[ https://issues.apache.org/jira/browse/KAFKA-7492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mariam John reassigned KAFKA-7492: -- Assignee: Mariam John > Explain `null` handling for reduce and aggregate >

[jira] [Assigned] (KAFKA-7243) Add unit integration tests to validate metrics in Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mariam John reassigned KAFKA-7243: -- Assignee: Mariam John > Add unit integration tests to validate metrics in Kafka Streams >

[jira] [Assigned] (KAFKA-7492) Explain `null` handling for reduce and aggregate

[ https://issues.apache.org/jira/browse/KAFKA-7492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mariam John reassigned KAFKA-7492: -- Assignee: (was: Mariam John) > Explain `null` handling for reduce and aggregate >

[jira] [Assigned] (KAFKA-4650) Improve test coverage org.apache.kafka.streams.kstream.internals

[ https://issues.apache.org/jira/browse/KAFKA-4650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mariam John reassigned KAFKA-4650: -- Assignee: (was: Mariam John) > Improve test coverage

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

[ https://issues.apache.org/jira/browse/KAFKA-6708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mariam John reassigned KAFKA-6708: -- Assignee: (was: Mariam John) > Review Exception messages with regards to Serde Useage >

[jira] [Assigned] (KAFKA-2111) Command Line Standardization - Add Help Arguments & List Required Fields

[ https://issues.apache.org/jira/browse/KAFKA-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mariam John reassigned KAFKA-2111: -- Assignee: (was: Mariam John) > Command Line Standardization - Add Help Arguments & List

[jira] [Assigned] (KAFKA-2939) Make AbstractConfig.logUnused() tunable for clients

[ https://issues.apache.org/jira/browse/KAFKA-2939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mariam John reassigned KAFKA-2939: -- Assignee: (was: Mariam John) > Make AbstractConfig.logUnused() tunable for clients >

[jira] [Assigned] (KAFKA-7243) Add unit integration tests to validate metrics in Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mariam John reassigned KAFKA-7243: -- Assignee: (was: Mariam John) > Add unit integration tests to validate metrics in Kafka

[jira] [Commented] (KAFKA-7243) Add unit integration tests to validate metrics in Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16723121#comment-16723121 ] Mariam John commented on KAFKA-7243: Done.  > Add unit integration tests to validate metrics in