Package com.here.platform.data.client.service.stream.kafka

Class DirectKafkaSerialization

java.lang.Object

com.here.platform.data.client.service.stream.kafka.DirectKafkaSerialization

public class DirectKafkaSerialization
extends Object

Constructor Summary

Constructors

Constructor	Description
DirectKafkaSerialization()

Method Summary

Modifier and Type	Method	Description
static scala.util.Try<com.here.platform.data.client.scaladsl.StreamPartition>	parse(String layerId, boolean isCompressed, org.apache.kafka.clients.consumer.ConsumerRecord<String,byte[]> record)
static scala.util.Try<BatchPublicationNotification>	parseNotification(org.apache.kafka.clients.consumer.ConsumerRecord<String,byte[]> record)
static org.apache.kafka.clients.producer.ProducerRecord<String,byte[]>	serialize(String topic, PublishPartition partition, boolean isCompressed)

Methods inherited from class java.lang.Object

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

Constructor Details

DirectKafkaSerialization

public DirectKafkaSerialization()

Method Details

parseNotification

public static scala.util.Try<BatchPublicationNotification> parseNotification(org.apache.kafka.clients.consumer.ConsumerRecord<String,byte[]> record)

parse

public static scala.util.Try<com.here.platform.data.client.scaladsl.StreamPartition> parse(String layerId,
 boolean isCompressed,
 org.apache.kafka.clients.consumer.ConsumerRecord<String,byte[]> record)

serialize

public static org.apache.kafka.clients.producer.ProducerRecord<String,byte[]> serialize(String topic,
 PublishPartition partition,
 boolean isCompressed)