KTable<String, String> t = builder.table("topicName", Consumed.with(Serdes.String(), Serdes.String()).withOffsetResetPolicy(Topology.AutoOffsetReset.EARLIEST), Materialized.as("topicStore"))
${application id}-topicStore-changelog
Am I missing something?
By the way this is for kafka-streams v1.0
thanks again.
> an email to confluent-platform+unsub...@googlegroups.com
> <mailto:confluent-platform+unsub...@googlegroups.com>.