the topology builder as well. Do you want to file a JIRA to keep
> track of this?
>
>
> Guozhang
>
> On Wed, May 18, 2016 at 11:36 AM, Fred Patton
> wrote:
>
> > Thanks, so much, Guozhang. It didn't work immediately when I tried end of
> > day, so
change:
>
> In configure(Map configs, boolean isKey) function, add the
> following key-value pair to the configs before calling inner.configure:
>
> configs.put("specific.avro.reader", "true");
>
>
> Guozhang
>
> On Tue, May 17, 2016 at 11:35 AM, Fred P
println("filteredSourceStream value: " + value)
value
})
.process(new CdcProcessorSupplier)
val stream: KafkaStreams = new KafkaStreams(builder, streamingConfig)
println("\nstart filtering BcAccessLog test run: " + testRun + "\n")
stream.start()
}
Regards,
Fred Patton
