housepower / clickhouse_sinker

Easily load data from kafka to ClickHouse
https://housepower.github.io/clickhouse_sinker
Apache License 2.0
519 stars 117 forks source link

Consume kafka topic with smallest offset #7

Closed hanguyen6 closed 5 years ago

hanguyen6 commented 5 years ago

Hi,

I run a simple test and see that when the sinker restarts it recorded last committed offset and can pick up where it left off.

Can we restart the sinker to process with offset largest/smallest ?

Thanks,

sundy-li commented 5 years ago

Hi, I have added this feature, plz see v1.2 release notes.

sundy-li commented 5 years ago

And here is the sample config