Consume data streams from a Kafka topic, archive the data packets into the TDEngine time series database.