Re: [DISCUSSION] KIP-418: A method-chaining way to branch KStream

I’d like to propose a different way of thinking about this. To me, there are three problems with the existing branch signature: 1. If you use it the way most people do, Java raises unsafe type warnings. 2. The way in which you use the stream branches is positionally coupled to the ordering of the

Re: [DISCUSSION] KIP-418: A method-chaining way to branch KStream

leanly access the individual branches (eg by mapping > > name->stream), which I thought was the original intention of this KIP. > > > > That said, I don't think we should so easily give in to the double brace > > anti-pattern or force ours users into it if at all po

Re: [DISCUSSION] KIP-418: A method-chaining way to branch KStream

` (that is essential) easier to grasp. > > >> > > >>>>>> Map> branches = stream.split() > > >>>>>>.branch("branchOne", Predicate) > > >>>>>>.branch( "branchTwo", Pred

[jira] [Created] (KAFKA-7855) Kafka Streams Maven Archetype quickstart fails to compile out of the box

Michael Drogalis created KAFKA-7855: --- Summary: Kafka Streams Maven Archetype quickstart fails to compile out of the box Key: KAFKA-7855 URL: https://issues.apache.org/jira/browse/KAFKA-7855 Project

[jira] [Created] (KAFKA-8181) Streams docs on serialization include Avro header, but no content

Michael Drogalis created KAFKA-8181: --- Summary: Streams docs on serialization include Avro header, but no content Key: KAFKA-8181 URL: https://issues.apache.org/jira/browse/KAFKA-8181 Project: Kafka

[jira] [Created] (KAFKA-8198) KStreams testing docs use non-existent method "pipe"

Michael Drogalis created KAFKA-8198: --- Summary: KStreams testing docs use non-existent method "pipe" Key: KAFKA-8198 URL: https://issues.apache.org/jira/browse/KAFKA-8198 Proj

[jira] [Created] (KAFKA-8200) TopologyTestDriver should offer an iterable signature of readOutput

Michael Drogalis created KAFKA-8200: --- Summary: TopologyTestDriver should offer an iterable signature of readOutput Key: KAFKA-8200 URL: https://issues.apache.org/jira/browse/KAFKA-8200 Project

[jira] [Created] (KAFKA-8208) Broken link for out-of-order data in KStreams Core Concepts doc

Michael Drogalis created KAFKA-8208: --- Summary: Broken link for out-of-order data in KStreams Core Concepts doc Key: KAFKA-8208 URL: https://issues.apache.org/jira/browse/KAFKA-8208 Project: Kafka

[jira] [Created] (KAFKA-8209) Wrong link for KStreams DSL in Core Concepts doc

Michael Drogalis created KAFKA-8209: --- Summary: Wrong link for KStreams DSL in Core Concepts doc Key: KAFKA-8209 URL: https://issues.apache.org/jira/browse/KAFKA-8209 Project: Kafka Issue

[jira] [Created] (KAFKA-8210) Missing link for KStreams in Streams DSL docs

Michael Drogalis created KAFKA-8210: --- Summary: Missing link for KStreams in Streams DSL docs Key: KAFKA-8210 URL: https://issues.apache.org/jira/browse/KAFKA-8210 Project: Kafka Issue Type

[jira] [Created] (KAFKA-8212) KStreams documentation Maven artifact table is cut off

Michael Drogalis created KAFKA-8212: --- Summary: KStreams documentation Maven artifact table is cut off Key: KAFKA-8212 URL: https://issues.apache.org/jira/browse/KAFKA-8212 Project: Kafka

[jira] [Created] (KAFKA-8213) KStreams interactive query documentation typo

Michael Drogalis created KAFKA-8213: --- Summary: KStreams interactive query documentation typo Key: KAFKA-8213 URL: https://issues.apache.org/jira/browse/KAFKA-8213 Project: Kafka Issue Type

[jira] [Created] (KAFKA-8296) Kafka Streams branch method raises type warnings

Michael Drogalis created KAFKA-8296: --- Summary: Kafka Streams branch method raises type warnings Key: KAFKA-8296 URL: https://issues.apache.org/jira/browse/KAFKA-8296 Project: Kafka Issue

[jira] [Created] (KAFKA-8297) Kafka Streams ConsumerRecordFactory yields difficult compiler error about generics

Michael Drogalis created KAFKA-8297: --- Summary: Kafka Streams ConsumerRecordFactory yields difficult compiler error about generics Key: KAFKA-8297 URL: https://issues.apache.org/jira/browse/KAFKA-8297