Package com.avoka.fc.core.stream.adapter

Class KafkaStreamDataAdapter<T>

java.lang.Object

com.avoka.fc.core.stream.adapter.KafkaStreamDataAdapter<T>

Type Parameters:

T - the type of data in the Kafka ConsumerRecords

public class KafkaStreamDataAdapter<T>
extends Object

Adapts Kafka ConsumerRecords to StreamData This class adapts Kafka ConsumerRecords to a Generic StreamData instance

Since:

24.4.0

Constructor Summary

Constructors

Constructor	Description
KafkaStreamDataAdapter(org.apache.kafka.clients.consumer.ConsumerRecords<String,T> consumerRecords)	Constructs a KafkaStreamDataAdapter instance with the given ConsumerRecords.

Method Summary

Modifier and Type	Method	Description
StreamData<T>	streamData()	Converts Kafka ConsumerRecords to a StreamData instance.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

KafkaStreamDataAdapter

public KafkaStreamDataAdapter(org.apache.kafka.clients.consumer.ConsumerRecords<String,T> consumerRecords)

Constructs a KafkaStreamDataAdapter instance with the given ConsumerRecords.

Parameters:

consumerRecords - the Kafka ConsumerRecords to adapt

Method Details

streamData

public StreamData<T> streamData()

Converts Kafka ConsumerRecords to a StreamData instance.

Returns:

a StreamData instance containing the adapted stream data