public class Config extends Object
Modifier and Type | Method and Description |
---|---|
static String |
getBootStrapServers() |
static Properties |
getConsumerConfig(String caller) |
static Properties |
getDefaultConfig() |
static Properties |
getDefaultConfigFromProps(String fileName) |
static Properties |
getProducerConfig(String caller) |
static Properties |
getSnapshotConsumerConfig() |
static Properties |
getSnapshotProducerConfig() |
public static final String BOOTSTRAP_SERVERS_KEY
public static final String DEFAULT_KAFKA_PORT
public static final String NAMESPACE
public static final String DEFAULT_CONTROL_TOPIC
public static final String DEFAULT_SNAPSHOT_TOPIC
public static final String ITERATION_BETWEEN_SNAPSHOT
public static final int DEFAULT_ITERATION_BETWEEN_SNAPSHOT
public static final String DEFAULT_PRINTER_TYPE
public static final String MAX_SNAPSHOT_AGE
public static final String DEFAULT_MAX_SNAPSHOT_AGE_SEC
public static final String MY_CLUSTER_KAFKA_BOOTSTRAP_SERVICE_HOST
public static final String BROKER_URL
public static final int DEFAULT_POLL_TIMEOUT
public static final int DEFAULT_POLL_SNAPSHOT_TIMEOUT
public static final String POLL_TIMEOUT
public static final String POLL_TIMEOUT_SNAPSHOT
public static final String POLL_TIMEOUT_UNIT
public static final String POLL_TIMEOUT_UNIT_SNAPSHOT
public static final PollUnit POLL_TIMEOUT_DEFAULT_UNIT
public static final PollUnit POLL_TIMEOUT_SNAPSHOT_DEFAULT_UNIT
public static final String SKIP_ON_DEMAND_SNAPSHOT
public static final String TEST
public static final String UNDER_TEST
public static final String MAX_SNAPSHOT_REQUEST_ATTEMPTS
public static final String UPDATABLE_KJAR
public static final String KJAR_GAV
public static final String DEFAULT_MAX_SNAPSHOT_REQUEST_ATTEMPTS
public static String getBootStrapServers()
public static Properties getDefaultConfig()
public static Properties getConsumerConfig(String caller)
public static Properties getProducerConfig(String caller)
public static Properties getSnapshotConsumerConfig()
public static Properties getSnapshotProducerConfig()
public static Properties getDefaultConfigFromProps(String fileName)
Copyright © 2001–2020 JBoss by Red Hat. All rights reserved.