[jira] [Commented] (KAFKA-7653) Streams-Scala: Add type level differentiation for Key and Value serdes.

[ https://issues.apache.org/jira/browse/KAFKA-7653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16694382#comment-16694382 ] Michael Noll commented on KAFKA-7653: - For [~mark.tranter]: If this change does require a KIP (Kafka

[jira] [Commented] (KAFKA-7653) Streams-Scala: Add type level differentiation for Key and Value serdes.

[ https://issues.apache.org/jira/browse/KAFKA-7653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16693645#comment-16693645 ] Michael Noll commented on KAFKA-7653: - Ack, [~mark.tranter]! {quote}Something Like KeySerde[T] and

[jira] [Commented] (KAFKA-7653) Streams-Scala: Add type level differentiation for Key and Value serdes.

[ https://issues.apache.org/jira/browse/KAFKA-7653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16692148#comment-16692148 ] Michael Noll commented on KAFKA-7653: - Thanks for raising this, [~mark.tranter]! The issue makes

[jira] [Commented] (KAFKA-4601) Avoid duplicated repartitioning in KStream DSL

[ https://issues.apache.org/jira/browse/KAFKA-4601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16678379#comment-16678379 ] Michael Noll commented on KAFKA-4601: - [~bbejeck]: With the recent topology optimization (merging of

[jira] [Created] (KAFKA-6871) KStreams Scala API: incorrect Javadocs and misleading parameter name

Michael Noll created KAFKA-6871: --- Summary: KStreams Scala API: incorrect Javadocs and misleading parameter name Key: KAFKA-6871 URL: https://issues.apache.org/jira/browse/KAFKA-6871 Project: Kafka

[jira] [Commented] (KAFKA-5037) Infinite loop if all input topics are unknown at startup

[ https://issues.apache.org/jira/browse/KAFKA-5037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16447385#comment-16447385 ] Michael Noll commented on KAFKA-5037: - Ping – any update on this? > Infinite loop if all input topics

[jira] [Commented] (KAFKA-6555) Making state store queryable during restoration

[ https://issues.apache.org/jira/browse/KAFKA-6555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16442006#comment-16442006 ] Michael Noll commented on KAFKA-6555: - Any updates here [~asurana]? > Making state store queryable

[jira] [Commented] (KAFKA-5037) Infinite loop if all input topics are unknown at startup

[ https://issues.apache.org/jira/browse/KAFKA-5037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16153928#comment-16153928 ] Michael Noll commented on KAFKA-5037: - Ping [~mjsax]: do we target this for 1.0.0? > Infinite loop if

[jira] [Commented] (KAFKA-5749) Refactor SessionStore hierarchy

[ https://issues.apache.org/jira/browse/KAFKA-5749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16137085#comment-16137085 ] Michael Noll commented on KAFKA-5749: - Thanks for wanting to contribute, Andrey! Perhaps you could

[jira] [Created] (KAFKA-5636) DSL: allow sliding windows to be used directly (i.e. not just implicitly when doing joins)

Michael Noll created KAFKA-5636: --- Summary: DSL: allow sliding windows to be used directly (i.e. not just implicitly when doing joins) Key: KAFKA-5636 URL: https://issues.apache.org/jira/browse/KAFKA-5636