Class KafkaRecordPosterAsJsonArray
- java.lang.Object
-
- com.scaleoutsoftware.soss.client.kafka.streaming.KafkaRecordPoster
-
- com.scaleoutsoftware.digitaltwin.datasource.kafka.KafkaRecordPosterAsJsonArray
-
- All Implemented Interfaces:
java.io.Serializable
public class KafkaRecordPosterAsJsonArray extends com.scaleoutsoftware.soss.client.kafka.streaming.KafkaRecordPoster
The KafkaRecordPosterAsJsonArray concatenates consumed messages for a given DigitalTwin and posts the list of messages to the DigitalTwin.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description KafkaRecordPosterAsJsonArray(java.lang.String friendlyName, java.lang.String topic, int sourceAppId)
-
Method Summary
Modifier and Type Method Description void
processAndPostRecords(com.scaleoutsoftware.soss.client.NamedCache namedCache, com.scaleoutsoftware.soss.reactive.Pipeline pipeline, org.apache.kafka.clients.consumer.ConsumerRecords consumerRecords)
static void
refreshStatus(java.lang.String friendlyName)
-
-
-
Method Detail
-
processAndPostRecords
public void processAndPostRecords(com.scaleoutsoftware.soss.client.NamedCache namedCache, com.scaleoutsoftware.soss.reactive.Pipeline pipeline, org.apache.kafka.clients.consumer.ConsumerRecords consumerRecords) throws com.scaleoutsoftware.soss.client.NamedCacheException
- Specified by:
processAndPostRecords
in classcom.scaleoutsoftware.soss.client.kafka.streaming.KafkaRecordPoster
- Throws:
com.scaleoutsoftware.soss.client.NamedCacheException
-
refreshStatus
public static void refreshStatus(java.lang.String friendlyName)
-
-