Hi guys,
I have an issue initializing a TimestampExtractor in KafkaStreams.
The following (static) initialization works great:
*config.put("timestamp.extractor", MyTimestampExtractor.class.getName());*
But when trying to initialize with an instance of the class as follows:
*config.put("timestamp.extractor", new MyTimestampExtractor());*
I get the following error:
Invalid value
com.myheritage.data.kafkastreamproc.CdcProcessor$MyTimestampExtractor@50c87b21
for configuration timestamp.extractor: Expected a Class instance or class
name.
Is this a bug or am I missing something here?
Thanks.
*Ofir Sharony*
BackEnd Tech Lead
Mobile: +972-54-7560277 | ofir.shar...@myheritage.com | www.myheritage.com
MyHeritage Ltd., 3 Ariel Sharon St., Or Yehuda 60250, Israel
<http://www.myheritage.com/>
<https://www.facebook.com/myheritage>
<https://twitter.com/myheritage> <http://blog.myheritage.com/>
<https://www.youtube.com/user/MyHeritageLtd>
