Skip to content

Instantly share code, notes, and snippets.

@suikast42
suikast42 / KafkaToTimeScaleBatchingService.java
Last active Jan 26, 2021
Spring Boot -> Kafka Stream -> TimeScaleDB over JTA
View KafkaToTimeScaleBatchingService.java
package com.boxbay.wms.bi.batch;
import com.boxbay.wms.bi.configuartion.serde.DeviceMovesSerde;
import com.boxbay.wms.bi.configuartion.topic.TopicConfiguration;
import com.boxbay.wms.bi.model.DeviceMoveTracking;
import com.boxbay.wms.commons.datetime.DateTime;
import org.apache.kafka.clients.consumer.ConsumerConfig;
import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.apache.kafka.common.serialization.StringDeserializer;
import org.springframework.beans.factory.annotation.Autowired;