[jira] [Commented] (KAFKA-9390) Non-key joining of KTable not compatible with confluent avro serdes

[ https://issues.apache.org/jira/browse/KAFKA-9390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17011427#comment-17011427 ] Andy Bryant commented on KAFKA-9390: Also I'm using the 2.4 version of Kafka Streams with 5.3.2

[jira] [Comment Edited] (KAFKA-9390) Non-key joining of KTable not compatible with confluent avro serdes

[ https://issues.apache.org/jira/browse/KAFKA-9390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17011426#comment-17011426 ] Andy Bryant edited comment on KAFKA-9390 at 1/9/20 5:25 AM: Here's the code

[jira] [Commented] (KAFKA-9390) Non-key joining of KTable not compatible with confluent avro serdes

[ https://issues.apache.org/jira/browse/KAFKA-9390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17011426#comment-17011426 ] Andy Bryant commented on KAFKA-9390: Here's the code snipped. I'm joining the orders table to the

[jira] [Created] (KAFKA-9390) Non-key joining of KTable not compatible with confluent avro serdes

Andy Bryant created KAFKA-9390: -- Summary: Non-key joining of KTable not compatible with confluent avro serdes Key: KAFKA-9390 URL: https://issues.apache.org/jira/browse/KAFKA-9390 Project: Kafka

[jira] [Commented] (KAFKA-7671) A KStream/GlobalKTable join shouldn't reset the repartition flag

[ https://issues.apache.org/jira/browse/KAFKA-7671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16701203#comment-16701203 ] Andy Bryant commented on KAFKA-7671: Hi [~mjsax], I just checked the old versions (1.1, 1.0, 0.11,

[jira] [Created] (KAFKA-7671) A KStream/GlobalKTable join shouldn't reset the repartition flag

Andy Bryant created KAFKA-7671: -- Summary: A KStream/GlobalKTable join shouldn't reset the repartition flag Key: KAFKA-7671 URL: https://issues.apache.org/jira/browse/KAFKA-7671 Project: Kafka

[jira] [Commented] (KAFKA-7608) A Kafka Streams DSL transform or process call should potentially trigger a repartition

[ https://issues.apache.org/jira/browse/KAFKA-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16688729#comment-16688729 ] Andy Bryant commented on KAFKA-7608: Hi Bill That sounds like a better solution. I see your point

[jira] [Comment Edited] (KAFKA-6641) Consider auto repartitioning for Stream.transform() API

[ https://issues.apache.org/jira/browse/KAFKA-6641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16679272#comment-16679272 ] Andy Bryant edited comment on KAFKA-6641 at 11/8/18 4:22 AM: - This is done

[jira] [Updated] (KAFKA-7608) A Kafka Streams DSL transform or process call should trigger a repartition, like a join

[ https://issues.apache.org/jira/browse/KAFKA-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andy Bryant updated KAFKA-7608: --- Summary: A Kafka Streams DSL transform or process call should trigger a repartition, like a join

[jira] [Updated] (KAFKA-7608) A Kafka Streams DSL transform or process call should potentially trigger a repartition

[ https://issues.apache.org/jira/browse/KAFKA-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andy Bryant updated KAFKA-7608: --- Summary: A Kafka Streams DSL transform or process call should potentially trigger a repartition

[jira] [Commented] (KAFKA-6641) Consider auto repartitioning for Stream.transform() API

[ https://issues.apache.org/jira/browse/KAFKA-6641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16679272#comment-16679272 ] Andy Bryant commented on KAFKA-6641: This is done now by the looks. In KStreamImpl.transform it

[jira] [Created] (KAFKA-7608) A Kafka Streams DSL transform or processor call should trigger a repartition like a join

Andy Bryant created KAFKA-7608: -- Summary: A Kafka Streams DSL transform or processor call should trigger a repartition like a join Key: KAFKA-7608 URL: https://issues.apache.org/jira/browse/KAFKA-7608

[jira] [Commented] (KAFKA-7373) GetOffsetShell doesn't work when SSL authentication is enabled

[ https://issues.apache.org/jira/browse/KAFKA-7373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16606492#comment-16606492 ] Andy Bryant commented on KAFKA-7373: Thanks Stanislav - good spot on the KIP. Hopefully that one

[jira] [Commented] (KAFKA-5235) GetOffsetShell: retrieve offsets for all given topics and partitions with single request to the broker

[ https://issues.apache.org/jira/browse/KAFKA-5235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16606488#comment-16606488 ] Andy Bryant commented on KAFKA-5235: Looking forward to this KIP being implemented. We currently

[jira] [Created] (KAFKA-7373) GetOffsetShell doesn't work when SSL authentication is enabled

Andy Bryant created KAFKA-7373: -- Summary: GetOffsetShell doesn't work when SSL authentication is enabled Key: KAFKA-7373 URL: https://issues.apache.org/jira/browse/KAFKA-7373 Project: Kafka

[jira] [Comment Edited] (KAFKA-7051) Improve the efficiency of the ReplicaManager when there are many partitions

[ https://issues.apache.org/jira/browse/KAFKA-7051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16583248#comment-16583248 ] Andy Bryant edited comment on KAFKA-7051 at 8/17/18 1:23 AM: - We've seen the

[jira] [Commented] (KAFKA-7051) Improve the efficiency of the ReplicaManager when there are many partitions

[ https://issues.apache.org/jira/browse/KAFKA-7051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16583248#comment-16583248 ] Andy Bryant commented on KAFKA-7051: We've seen this codeblock taking considerable CPU and time when

[jira] [Commented] (KAFKA-2260) Allow specifying expected offset on produce

[ https://issues.apache.org/jira/browse/KAFKA-2260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16559225#comment-16559225 ] Andy Bryant commented on KAFKA-2260:  Would prove very handy in event source based designs > Allow

[jira] [Commented] (KAFKA-6378) NullPointerException on KStream-GlobalKTable leftJoin when KeyValueMapper returns null

[ https://issues.apache.org/jira/browse/KAFKA-6378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16349439#comment-16349439 ] Andy Bryant commented on KAFKA-6378: Thanks [~guozhang] - much appreciated! > NullPointerException on

[jira] [Commented] (KAFKA-6378) NullPointerException on KStream-GlobalKTable leftJoin when KeyValueMapper returns null

[ https://issues.apache.org/jira/browse/KAFKA-6378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16322091#comment-16322091 ] Andy Bryant commented on KAFKA-6378: Sure thing Matthias. Will try and get that out tomorrow >

[jira] [Commented] (KAFKA-6378) NullPointerException on KStream-GlobalKTable leftJoin when KeyValueMapper returns null

[ https://issues.apache.org/jira/browse/KAFKA-6378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16321374#comment-16321374 ] Andy Bryant commented on KAFKA-6378: A sentinel value is ok where only a subset of the available

[jira] [Commented] (KAFKA-6378) NullPointerException on KStream-GlobalKTable leftJoin when KeyValueMapper returns null

[ https://issues.apache.org/jira/browse/KAFKA-6378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16303186#comment-16303186 ] Andy Bryant commented on KAFKA-6378: I can definitely see how having {{null}} keys is problematic, but

[jira] [Created] (KAFKA-6378) NullPointerException on KStream-GlobalKTable leftJoin when KeyValueMapper returns null

Andy Bryant created KAFKA-6378: -- Summary: NullPointerException on KStream-GlobalKTable leftJoin when KeyValueMapper returns null Key: KAFKA-6378 URL: https://issues.apache.org/jira/browse/KAFKA-6378