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)

Reply via email to