Open machty opened 7 years ago
FYI I "fixed" this by specifying a TIMESTAMP_EXTRACTOR_CLASS_CONFIG
of 'org.apache.kafka.streams.processor.WallclockTimestampExtractor'
in the consumer.
That said I'd still like to figure out what could/should change about BW to include timestamp information, otherwise we're limited to at-processing timestamps only (which is what the setting above accomplishes).
Thanks @machty - this solution worked for me also.
Thanks @machty - Above solution also worked for me.
Which config file do you add this to and what's the exact line?
Honestly I have no idea, never really stuck with this learning Kafka. I'd recommend you check out debezium rather than bottledwater though.
Thanks @machty. Above solution worked for me as well.
I'm trying to use Kafka-Streams to parse the data I've loaded into Kafka using Postgres and I'm getting
I found the following link http://docs.confluent.io/3.1.0/streams/faq.html#invalid-timestamp-exception
Am I possibly seeing this error because bottlewater was built for 0.9 and doesn't have proper timestamps for 0.10?