Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
CONNECTOR_ASYNC_COMMIT_ENABLE |
"bullet.dsl.connector.async.commit.enable" |
public static final String |
CONNECTOR_CLASS_NAME |
"bullet.dsl.connector.class.name" |
public static final String |
CONNECTOR_KAFKA_BOOTSTRAP_SERVERS |
"bullet.dsl.connector.kafka.bootstrap.servers" |
public static final String |
CONNECTOR_KAFKA_ENABLE_AUTO_COMMIT |
"bullet.dsl.connector.kafka.enable.auto.commit" |
public static final String |
CONNECTOR_KAFKA_GROUP_ID |
"bullet.dsl.connector.kafka.group.id" |
public static final String |
CONNECTOR_KAFKA_KEY_DESERIALIZER |
"bullet.dsl.connector.kafka.key.deserializer" |
public static final String |
CONNECTOR_KAFKA_NAMESPACE |
"bullet.dsl.connector.kafka." |
public static final String |
CONNECTOR_KAFKA_START_AT_END_ENABLE |
"bullet.dsl.connector.kafka.start.at.end.enable" |
public static final String |
CONNECTOR_KAFKA_TOPICS |
"bullet.dsl.connector.kafka.topics" |
public static final String |
CONNECTOR_KAFKA_VALUE_DESERIALIZER |
"bullet.dsl.connector.kafka.value.deserializer" |
public static final String |
CONNECTOR_PULSAR_AUTH_ENABLE |
"bullet.dsl.connector.pulsar.auth.enable" |
public static final String |
CONNECTOR_PULSAR_AUTH_PARAMS_STRING |
"bullet.dsl.connector.pulsar.auth.params.string" |
public static final String |
CONNECTOR_PULSAR_AUTH_PLUGIN_CLASS_NAME |
"bullet.dsl.connector.pulsar.auth.plugin.class.name" |
public static final String |
CONNECTOR_PULSAR_CLIENT_NAMESPACE |
"bullet.dsl.connector.pulsar.client." |
public static final String |
CONNECTOR_PULSAR_CLIENT_SERVICE_URL |
"bullet.dsl.connector.pulsar.client.serviceUrl" |
public static final String |
CONNECTOR_PULSAR_CONSUMER_NAMESPACE |
"bullet.dsl.connector.pulsar.consumer." |
public static final String |
CONNECTOR_PULSAR_CONSUMER_SUBSCRIPTION_NAME |
"bullet.dsl.connector.pulsar.consumer.subscriptionName" |
public static final String |
CONNECTOR_PULSAR_CONSUMER_SUBSCRIPTION_TYPE |
"bullet.dsl.connector.pulsar.consumer.subscriptionType" |
public static final String |
CONNECTOR_PULSAR_SCHEMA_CLASS_NAME |
"bullet.dsl.connector.pulsar.schema.class.name" |
public static final String |
CONNECTOR_PULSAR_SCHEMA_TYPE |
"bullet.dsl.connector.pulsar.schema.type" |
public static final String |
CONNECTOR_PULSAR_TOPICS |
"bullet.dsl.connector.pulsar.topics" |
public static final String |
CONNECTOR_READ_TIMEOUT_MS |
"bullet.dsl.connector.read.timeout.ms" |
public static final boolean |
DEFAULT_CONNECTOR_ASYNC_COMMIT_ENABLE |
true |
public static final boolean |
DEFAULT_CONNECTOR_KAFKA_ENABLE_AUTO_COMMIT |
true |
public static final boolean |
DEFAULT_CONNECTOR_KAFKA_START_AT_END_ENABLE |
false |
public static final boolean |
DEFAULT_CONNECTOR_PULSAR_AUTH_ENABLE |
false |
public static final String |
DEFAULT_CONNECTOR_PULSAR_CONSUMER_SUBSCRIPTION_TYPE |
"Shared" |
public static final String |
DEFAULT_CONNECTOR_PULSAR_SCHEMA_TYPE |
"BYTES" |
public static final int |
DEFAULT_CONNECTOR_READ_TIMEOUT_MS |
0 |
public static final boolean |
DEFAULT_CONVERTER_AVRO_STRING_TYPE_FIX_ENABLE |
false |
public static final boolean |
DEFAULT_CONVERTER_TYPE_CHECK_ENABLE |
false |
public static final String |
DEFAULT_DSL_CONFIGURATION |
"bullet_dsl_defaults.yaml" |
public static final String |
DESERIALIZER_AVRO_CLASS_NAME |
"bullet.dsl.deserializer.avro.class.name" |
public static final String |
DESERIALIZER_AVRO_SCHEMA_FILE |
"bullet.dsl.deserializer.avro.schema.file" |
public static final String |
DESERIALIZER_CLASS_NAME |
"bullet.dsl.deserializer.class.name" |
public static final String |
FILE_PREFIX |
"file://" |
public static final String |
PULSAR_SCHEMA_AVRO |
"AVRO" |
public static final String |
PULSAR_SCHEMA_BYTES |
"BYTES" |
public static final String |
PULSAR_SCHEMA_CUSTOM |
"CUSTOM" |
public static final String |
PULSAR_SCHEMA_JSON |
"JSON" |
public static final String |
PULSAR_SCHEMA_PROTOBUF |
"PROTOBUF" |
public static final String |
PULSAR_SCHEMA_STRING |
"STRING" |
public static final String |
RECORD_CONVERTER_AVRO_STRING_TYPE_FIX_ENABLE |
"bullet.dsl.converter.avro.string.type.fix.enable" |
public static final String |
RECORD_CONVERTER_CLASS_NAME |
"bullet.dsl.converter.class.name" |
public static final String |
RECORD_CONVERTER_POJO_CLASS_NAME |
"bullet.dsl.converter.pojo.class.name" |
public static final String |
RECORD_CONVERTER_SCHEMA_FILE |
"bullet.dsl.converter.schema.file" |
public static final String |
RECORD_CONVERTER_SCHEMA_TYPE_CHECK_ENABLE |
"bullet.dsl.converter.schema.type.check.enable" |
Copyright © 2021. All rights reserved.