public class KafkaManager extends AbstractManager
Modifier and Type | Field and Description |
---|---|
static String |
DEFAULT_TIMEOUT_MILLIS |
count, LOGGER
Constructor and Description |
---|
KafkaManager(String name,
String topic,
Property[] properties) |
Modifier and Type | Method and Description |
---|---|
void |
releaseSub()
May be overridden by Managers to perform processing while the Manager is being released and the
lock is held.
|
void |
send(byte[] msg) |
void |
startup() |
getContentFormat, getCount, getManager, getName, hasManager, release
public static final String DEFAULT_TIMEOUT_MILLIS
public void releaseSub()
AbstractManager
releaseSub
in class AbstractManager
public void send(byte[] msg) throws ExecutionException, InterruptedException, TimeoutException
public void startup()
Copyright © 1999-2021 Apache Software Foundation. All Rights Reserved.
Apache Logging, Apache Log4j, Log4j, Apache, the Apache feather logo, the Apache Logging project logo, and the Apache Log4j logo are trademarks of The Apache Software Foundation.