public static final java.lang.String |
AUTO_OFFSET_RESET_CONFIG |
"auto.offset.reset" |
public static final java.lang.String |
BOOTSTRAP_SERVERS_CONFIG |
"bootstrap.servers" |
public static final java.lang.String |
BUFFERED_RECORDS_PER_PARTITION_CONFIG |
"buffered.records.per.partition" |
public static final java.lang.String |
CLIENT_ID_CONFIG |
"client.id" |
public static final java.lang.String |
COMMIT_INTERVAL_MS_CONFIG |
"commit.interval.ms" |
public static final java.lang.String |
JOB_ID_CONFIG |
"job.id" |
public static final java.lang.String |
JOB_ID_DOC |
"An id string to identify for the stream job. It is used as 1) the default client-id prefix, 2) the group-id for membership management, 3) the changelog topic prefix." |
public static final java.lang.String |
KEY_DESERIALIZER_CLASS_CONFIG |
"key.deserializer" |
public static final java.lang.String |
KEY_SERIALIZER_CLASS_CONFIG |
"key.serializer" |
public static final java.lang.String |
METRIC_REPORTER_CLASSES_CONFIG |
"metric.reporters" |
public static final java.lang.String |
METRICS_NUM_SAMPLES_CONFIG |
"metrics.num.samples" |
public static final java.lang.String |
METRICS_SAMPLE_WINDOW_MS_CONFIG |
"metrics.sample.window.ms" |
public static final java.lang.String |
NUM_STANDBY_REPLICAS_CONFIG |
"num.standby.replicas" |
public static final java.lang.String |
NUM_STREAM_THREADS_CONFIG |
"num.stream.threads" |
public static final java.lang.String |
PARTITION_GROUPER_CLASS_CONFIG |
"partition.grouper" |
public static final java.lang.String |
POLL_MS_CONFIG |
"poll.ms" |
public static final java.lang.String |
REPLICATION_FACTOR_CONFIG |
"replication.factor" |
public static final java.lang.String |
REPLICATION_FACTOR_DOC |
"The replication factor for change log topics and repartition topics created by the job." |
public static final java.lang.String |
STATE_CLEANUP_DELAY_MS_CONFIG |
"state.cleanup.delay.ms" |
public static final java.lang.String |
STATE_DIR_CONFIG |
"state.dir" |
public static final java.lang.String |
TIMESTAMP_EXTRACTOR_CLASS_CONFIG |
"timestamp.extractor" |
public static final java.lang.String |
VALUE_DESERIALIZER_CLASS_CONFIG |
"value.deserializer" |
public static final java.lang.String |
VALUE_SERIALIZER_CLASS_CONFIG |
"value.serializer" |
public static final java.lang.String |
ZOOKEEPER_CONNECT_CONFIG |
"zookeeper.connect" |