Guozhang Wang created KAFKA-3121: ------------------------------------ Summary: KStream DSL API Improvement Key: KAFKA-3121 URL: https://issues.apache.org/jira/browse/KAFKA-3121 Project: Kafka Issue Type: Sub-task Reporter: Guozhang Wang Assignee: Guozhang Wang
>From some collected feedbacks, here is a list of potential improvements that >we want to make: 1. Remove AggregateSupplier for aggregate, and provide more built-in aggregations. 2. Join to return KeyValue<>. 3. "Windows" class syntax-sugers. 4. Add print() to KTable / KStream. 5. flatMap / flatMapValues to return arrays in addition to Iterable. 6. make the API function names aligned with Java 8+, e.g. filterOut -> filterNot -- This message was sent by Atlassian JIRA (v6.3.4#6332)