Class KafkaAdapterUtil

java.lang.Object

io.nosqlbench.adapter.kafka.util.KafkaAdapterUtil

public class KafkaAdapterUtil
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	KafkaAdapterUtil.DOC_LEVEL_PARAMS	////

Field Summary

Fields

Modifier and Type	Field	Description
static String	DFT_CONSUMER_GROUP_NAME_PREFIX
static String	DFT_TOPIC_NAME_PREFIX
static final String	MSG_SEQUENCE_NUMBER
static final String	NB_MSG_SEQ_PROP
static final String	NB_MSG_SIZE_PROP

Constructor Summary

Constructors

Constructor	Description
KafkaAdapterUtil()

Method Summary

Modifier and Type	Method	Description
static Map<String,String>	convertJsonToMap(String jsonStr)
static List<Object>	convertJsonToObjList(String jsonStr)
static String	getSimplifiedNBThreadName(String fullThreadName)
static int	getStrObjSize(String strObj)
static void	messageErrorHandling(Exception exception, boolean strictErrorHandling, String errorMsg)
static void	pauseCurThreadExec(int pauseInSec)

Methods inherited from class java.lang.Object

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

Field Details

MSG_SEQUENCE_NUMBER

public static final String MSG_SEQUENCE_NUMBER

See Also:

• Constant Field Values

DFT_CONSUMER_GROUP_NAME_PREFIX

public static String DFT_CONSUMER_GROUP_NAME_PREFIX

DFT_TOPIC_NAME_PREFIX

public static String DFT_TOPIC_NAME_PREFIX

NB_MSG_SEQ_PROP

public static final String NB_MSG_SEQ_PROP

See Also:

• Constant Field Values

NB_MSG_SIZE_PROP

public static final String NB_MSG_SIZE_PROP

See Also:

• Constant Field Values

Constructor Details

KafkaAdapterUtil

public KafkaAdapterUtil()

Method Details

getSimplifiedNBThreadName

public static String getSimplifiedNBThreadName(String fullThreadName)

convertJsonToMap

public static Map<String,String> convertJsonToMap(String jsonStr)
                                           throws Exception

Throws:

Exception

convertJsonToObjList

public static List<Object> convertJsonToObjList(String jsonStr)
                                         throws Exception

Throws:

Exception

pauseCurThreadExec

public static void pauseCurThreadExec(int pauseInSec)

getStrObjSize

public static int getStrObjSize(String strObj)

messageErrorHandling

public static void messageErrorHandling(Exception exception,
 boolean strictErrorHandling,
 String errorMsg)