search

doujiang24 / lua-resty-kafka

Lua kafka client driver for the Openresty based on the cosocket API
BSD 3-Clause "New" or "Revised" License
802 stars 275 forks source link

No timestamp supported? #69

Open echovalley opened 6 years ago

echovalley commented 6 years ago

I try to send two messages which are used to join stream. But StreamsException report that is no timestamp found, which is necessary for stream joining operation. Does this module not suport timestamp yet?

ZhouBox commented 5 years ago

When I use KSQL, "has invalid (negative) timestamp. Possibly because a pre-0.10 producer client was used to write this record to Kafka without embedding a timestamp, or because the input topic was created before upgrading the Kafka cluster to 0.10+. Use a different TimestampExtractor to process this data."