org.thales.punch.libraries.storm.util

Class KafkaHeaderReader

java.lang.Object

org.thales.punch.libraries.storm.util.KafkaHeaderReader

public class KafkaHeaderReader
extends Object

This static class allows to decode kafka headers according to storm configuration 'headers_fields' The resulting HeaderDeclaration object is used to cast the header value according to its type, encoding or byte ordering

Author:

lca

Method Summary

Modifier and Type	Method and Description
static Object	readValue(org.apache.kafka.common.header.Header header, org.thales.punch.libraries.storm.api.HeaderDeclaration headerDeclaration) Return a header value according to its configured declaration For accepted value type and encodings, check @HeaderDeclaration class
static Integer	toInt(byte[] headerValue, org.thales.punch.libraries.storm.api.HeaderDeclaration declaration) byte kafka header content to integer value according to byte ordering in header declaration
static Long	toLong(byte[] headerValue, org.thales.punch.libraries.storm.api.HeaderDeclaration declaration) byte kafka header content to long value according to byte ordering in header declaration
static String	toString(byte[] headerValue, org.thales.punch.libraries.storm.api.HeaderDeclaration declaration) byte kafka header content to string value according to value type in header declaration

Methods inherited from class java.lang.Object

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

Method Detail

readValue

public static Object readValue(org.apache.kafka.common.header.Header header,
                               org.thales.punch.libraries.storm.api.HeaderDeclaration headerDeclaration)

Return a header value according to its configured declaration For accepted value type and encodings, check @HeaderDeclaration class

Parameters:

header - kafka custom header from record

headerDeclaration - configured header declaration with type, encoding, field name and behavior

Returns:

the supported value from the byte content

toString

public static String toString(byte[] headerValue,
                              org.thales.punch.libraries.storm.api.HeaderDeclaration declaration)

byte kafka header content to string value according to value type in header declaration

Parameters:

headerValue - kafka custom header value from record

declaration - configured header declaration with type, encoding, field name and behavior

Returns:

the string value from header bytes

toInt

public static Integer toInt(byte[] headerValue,
                            org.thales.punch.libraries.storm.api.HeaderDeclaration declaration)

byte kafka header content to integer value according to byte ordering in header declaration

Parameters:

headerValue - kafka custom header value from record

declaration - configured header declaration with type, byte ordering, field name and behavior

Returns:

the integer value from header bytes

toLong

public static Long toLong(byte[] headerValue,
                          org.thales.punch.libraries.storm.api.HeaderDeclaration declaration)

byte kafka header content to long value according to byte ordering in header declaration

Parameters:

headerValue - kafka custom header value from record

declaration - configured header declaration with type, byte ordering, field name and behavior

Returns:

the long value from header bytes