public class ConsumerUtils extends Object
Constructor and Description |
---|
ConsumerUtils() |
Modifier and Type | Method and Description |
---|---|
static FactCountMessage |
getFactCount(RemoteFactHandle factHandle,
EnvConfig config,
Properties properties) |
static ControlMessage |
getLastEvent(String topic,
Integer pollTimeout) |
static ControlMessage |
getLastEvent(String topic,
Properties properties,
Integer pollTimeout) |
Map<org.apache.kafka.common.TopicPartition,Long> |
getOffsets(String topic) |
public static ControlMessage getLastEvent(String topic, Integer pollTimeout)
public static ControlMessage getLastEvent(String topic, Properties properties, Integer pollTimeout)
public static FactCountMessage getFactCount(RemoteFactHandle factHandle, EnvConfig config, Properties properties)
Copyright © 2001–2020 JBoss by Red Hat. All rights reserved.