public class KafkaUtils extends Object
Constructor and Description |
---|
KafkaUtils() |
Modifier and Type | Method and Description |
---|---|
static void |
checkArgument(boolean arg) |
static int |
getIntFromConfig(Properties config,
String key,
int defaultValue) |
static long |
getLongFromConfig(Properties config,
String key,
long defaultValue) |
public static int getIntFromConfig(Properties config, String key, int defaultValue)
public static long getLongFromConfig(Properties config, String key, long defaultValue)
public static void checkArgument(boolean arg)
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.