public class NDArrayKafkaClient
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
NDARRAY_TYPE_HEADER |
Constructor and Description |
---|
NDArrayKafkaClient() |
Modifier and Type | Method and Description |
---|---|
NDArrayConsumer |
createConsumer() |
NDArrayPublisher |
createPublisher() |
public static final java.lang.String NDARRAY_TYPE_HEADER
public NDArrayPublisher createPublisher()
public NDArrayConsumer createConsumer()