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

2019-05-24 Thread Michael Drogalis
t() > > >>>>>>.branch("branchOne", Predicate) > > >>>>>>.branch( "branchTwo", Predicate) > > >>>>>>.defaultBranch("defaultBranch"); > > >> An open question is

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

2019-05-01 Thread Michael Drogalis
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 possible to > avoid...just > > my two cents

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

2019-04-30 Thread Michael Drogalis
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

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

2019-04-26 Thread Michael Drogalis (JIRA)
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

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

2019-04-26 Thread Michael Drogalis (JIRA)
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-8213) KStreams interactive query documentation typo

2019-04-10 Thread Michael Drogalis (JIRA)
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-8212) KStreams documentation Maven artifact table is cut off

2019-04-10 Thread Michael Drogalis (JIRA)
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-8210) Missing link for KStreams in Streams DSL docs

2019-04-10 Thread Michael Drogalis (JIRA)
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-8209) Wrong link for KStreams DSL in Core Concepts doc

2019-04-10 Thread Michael Drogalis (JIRA)
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-8208) Broken link for out-of-order data in KStreams Core Concepts doc

2019-04-10 Thread Michael Drogalis (JIRA)
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-8200) TopologyTestDriver should offer an iterable signature of readOutput

2019-04-08 Thread Michael Drogalis (JIRA)
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-8198) KStreams testing docs use non-existent method "pipe"

2019-04-05 Thread Michael Drogalis (JIRA)
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-8181) Streams docs on serialization include Avro header, but no content

2019-04-01 Thread Michael Drogalis (JIRA)
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-7855) Kafka Streams Maven Archetype quickstart fails to compile out of the box

2019-01-22 Thread Michael Drogalis (JIRA)
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