housepower / clickhouse_sinker

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

Use franz-go to calculate lags #155

Closed yuzhichang closed 2 years ago

yuzhichang commented 2 years ago

kadm.CalculateGroupLag looks better than sarama ClusterAdmin.ListConsumerGroupOffsets.