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

Class KafkaHeader

java.lang.Object

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

All Implemented Interfaces:

Serializable, org.apache.kafka.common.header.Header, scala.Equals, scala.Product

public class KafkaHeader
extends Object
implements org.apache.kafka.common.header.Header, scala.Product, Serializable

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
KafkaHeader(String key, byte[] value)

Method Summary

Modifier and Type	Method	Description
static KafkaHeader	empty(String key)
String	key()
static scala.Option<KafkaHeader>	maybeLong(String key, scala.Option<Object> maybeLong)
static scala.Option<KafkaHeader>	maybeString(String key, scala.Option<String> maybeString)
static long	readLong(String key, org.apache.kafka.common.header.Headers headers)
static scala.Option<Object>	readLongOpt(String key, org.apache.kafka.common.header.Headers headers)
static String	readString(String key, org.apache.kafka.common.header.Headers headers)
static scala.Option<String>	readStringOpt(String key, org.apache.kafka.common.header.Headers headers)
static KafkaHeader	string(String key, String str)
byte[]	value()

Methods inherited from class java.lang.Object

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

Methods inherited from interface scala.Equals

canEqual, equals

Methods inherited from interface scala.Product

productArity, productElement, productElementName, productElementNames, productIterator, productPrefix

Constructor Details

KafkaHeader

public KafkaHeader(String key,
 byte[] value)

Method Details

string

public static KafkaHeader string(String key,
 String str)

maybeString

public static scala.Option<KafkaHeader> maybeString(String key,
 scala.Option<String> maybeString)

maybeLong

public static scala.Option<KafkaHeader> maybeLong(String key,
 scala.Option<Object> maybeLong)

empty

public static KafkaHeader empty(String key)

readString

public static String readString(String key,
 org.apache.kafka.common.header.Headers headers)

readStringOpt

public static scala.Option<String> readStringOpt(String key,
 org.apache.kafka.common.header.Headers headers)

readLong

public static long readLong(String key,
 org.apache.kafka.common.header.Headers headers)

readLongOpt

public static scala.Option<Object> readLongOpt(String key,
 org.apache.kafka.common.header.Headers headers)

key

public String key()

Specified by:

key in interface org.apache.kafka.common.header.Header

value

public byte[] value()

Specified by:

value in interface org.apache.kafka.common.header.Header