Hello Ali, We do have corresponding overloaded functions for most of KStream / KTable operators to avoid enforcing users to specify "null"; in these cases the default serdes specified in the configs are then used. For example:
<T> KTable<K, T> aggregate(Initializer<T> initializer, Aggregator<K, V, T> adder, Aggregator<K, V, T> subtractor, Serde<T> aggValueSerde, String storeName); /** * .. using default serializers and deserializers. */ <T> KTable<K, T> aggregate(Initializer<T> initializer, Aggregator<K, V, T> adder, Aggregator<K, V, T> subtractor, String storeName); Guozhang On Fri, Oct 7, 2016 at 9:20 AM, Michael Noll <mich...@confluent.io> wrote: > Ali, the Apache Kafka project still targets Java 7, which means we can't > use Java 8 features just yet. > > FYI: There's on ongoing conversation about when Kafka would move from Java > 7 to Java 8. > > On Fri, Oct 7, 2016 at 6:14 PM, Ali Akhtar <ali.rac...@gmail.com> wrote: > > > Since we're using Java 8 in most cases anyway, Serdes / Serialiazers > should > > use options, to avoid having to deal with the lovely nulls. > > > -- -- Guozhang