Bulk Operation

KAFKA-2590 Allow for different "auto.offset.reset" strategies for different input streams

KAFKA-2590 Add initial set of integration tests

KAFKA-2590 Move WindowStoreUtils to package "internals"

KAFKA-2590 Improve JavaDoc of public API

KAFKA-2590 Unify KStream and KTable API

KAFKA-2590 Add missing @returns tags for JavaDoc

KAFKA-2590 Set curRecord in punctuate() functions

KAFKA-2590 Changelog partition configured to enable log compaction

KAFKA-2590 byte[] should not be used as Map key nor Set member

KAFKA-2590 Streams ProcessorContext should support forward() based on child name

KAFKA-2590 Finer Stream Flow Control

KAFKA-2590 Add customizable StreamPartition into #to functions of Streams DSL

KAFKA-2590 Connect custom processors with the streams DSL

KAFKA-2590 Rename filterOut() to filterNot() to achieve better terminology

KAFKA-2590 Support regex topics in addSource() and stream()

KAFKA-2590 Add Javadoc for KTable (changelog stream) and KStream (record stream)

KAFKA-2590 Document possible exception thrown in public APIs

KAFKA-2590 Allow users to set key in KTable.toStream() and KStream

KAFKA-2590 Add overloading functions for each operator not requiring serialization

KAFKA-2590 prefix job id to internal topic names

KAFKA-2590 Add print and writeAsText functions to the Streams DSL

KAFKA-2590 Extract selector as a separate groupBy operator for KTable aggregations

KAFKA-2590 Unify ser/de pair classes into one serde class

KAFKA-2590 Move co-partition checking to PartitionAssignor and auto-create internal topics

KAFKA-2590 need a way to specify the number of replicas for change log topics

KAFKA-2590 Race Condition for Repartition Topics

KAFKA-2590 Wait for producer message acks in StreamTask.commit()

KAFKA-2590 Add implicit unlimited windowed aggregation for KStream

KAFKA-2590 Serializer/Deserializer Registration and Type inference

KAFKA-2590 Improve error message in kstreams

KAFKA-2590 Rename KafkaStreaming to KafkaStreams

KAFKA-2590 Add putIfAbsent function to KeyValueStore

KAFKA-2590 Exception Hierarchy for Streams

KAFKA-2590 KStream DSL API Improvement

KAFKA-2590 KStream custom StreamPartitioner for windowed key

KAFKA-2590 Windowed Stream Aggregation Implementation

KAFKA-2590 KTable Aggregation Implementation

KAFKA-2590 Add Demo Examples for Kafka Streams

KAFKA-2590 Refactor MeteredXXStore

KAFKA-2590 Add KStream-KStream window joins

KAFKA-2590 KTable should send old values along with new values to downstreams

KAFKA-2590 Add Simple Join API

KAFKA-2590 add KTable

KAFKA-2590 Add standby tasks

KAFKA-2590 Create / Update changelog topics upon state store initialization

KAFKA-2590 Add integration tests for Kafka Streams

KAFKA-2590 Reduce stream task migrations and initialization costs

KAFKA-2590 Distinguish metric names inside the sensor registry

KAFKA-2590 initialize only the part of the topology relevant to the task

KAFKA-2590 Make KStream processor names deterministic

KAFKA-2590 Make state stores first class citizens in the processor DAG

KAFKA-2590 Make a task id be a composite id of a topic group id and a partition id

KAFKA-2590 Avoid calling Consumer.poll(0) in each iteration

KAFKA-2590 Stateful operations in the KStream DSL layer

KAFKA-2590 Incorporate the new consumer protocol with partition-group interface

KAFKA-2590 Add support for custom partitioner in sink nodes

KAFKA-2590 Make KStream interfaces compatible with Java 8 java.util.function

KAFKA-2590 Add a key-value store that is a fixed-capacity in-memory LRU cache

KAFKA-2590 KeyValueStores should not require use of the context's default serializers and deserializers

KAFKA-2590 Stop Writing the Change-log in store.put() / delete() for Non-transactional Store

KAFKA-2590 Remove Persistent Data before Restoringafter a Fault