Skip to content

Instantly share code, notes, and snippets.

View suikast42's full-sized avatar

Süleyman Vurucu suikast42

0 followers · 3 following
View GitHub Profile
@suikast42
suikast42 / KafkaToTimeScaleBatchingService.java
Last active January 26, 2021 07:41
Spring Boot -> Kafka Stream -> TimeScaleDB over JTA
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;