Also you should check how you insert the rows into TimescaleDB for performance reasons. We added quite a complicated batching logic to do it, so that we can achieve high insert rates: https://github.com/united-manufacturing-hub/united-manufacturing-hub/blob/main/golang/cmd/kafka-to-postgresql/pxProcessValue.go