public class SnapshotOnDemandUtilsImpl extends Object
Modifier and Type | Method and Description |
---|---|
static SnapshotInfos |
askASnapshotOnDemand(EnvConfig config,
SessionSnapshooter snapshooter,
Producer producer) |
static org.apache.kafka.clients.consumer.KafkaConsumer |
getConfiguredSnapshotConsumer(EnvConfig envConfig) |
public static SnapshotInfos askASnapshotOnDemand(EnvConfig config, SessionSnapshooter snapshooter, Producer producer)
public static org.apache.kafka.clients.consumer.KafkaConsumer getConfiguredSnapshotConsumer(EnvConfig envConfig)
Copyright © 2001–2020 JBoss by Red Hat. All rights reserved.