public static final java.lang.String |
AllowAutoCreateTopicsKey |
"datadistributionmanager.kafka.globalconf.allow.auto.create.topics" |
public static final java.lang.String |
ApiVersionFallbackKey |
"datadistributionmanager.kafka.globalconf.api.version.fallback.ms" |
public static final java.lang.String |
ApiVersionRequestKey |
"datadistributionmanager.kafka.globalconf.api.version.request" |
public static final java.lang.String |
ApiVersionRequestTimeoutKey |
"datadistributionmanager.kafka.globalconf.api.version.request.timeout.ms" |
public static final java.lang.String |
AutoCommitIntervalKey |
"datadistributionmanager.kafka.globalconf.auto.commit.interval.ms" |
public static final java.lang.String |
AutoOffsetResetKey |
"datadistributionmanager.kafka.topicconf.auto.offset.reset" |
public static final java.lang.String |
BatchNumMessagesKey |
"datadistributionmanager.kafka.globalconf.batch.num.messages" |
public static final java.lang.String |
BatchSizeKey |
"datadistributionmanager.kafka.globalconf.batch.size" |
public static final java.lang.String |
BootstrapBrokersKey |
"datadistributionmanager.kafka.globalconf.metadata.broker.list" |
public static final java.lang.String |
BrokerAddressFamilyKey |
"datadistributionmanager.kafka.globalconf.broker.address.family" |
public static final java.lang.String |
BrokerAddressTtlKey |
"datadistributionmanager.kafka.globalconf.broker.address.ttl" |
public static final java.lang.String |
BrokerVersionFallbackKey |
"datadistributionmanager.kafka.globalconf.broker.version.fallback" |
public static final java.lang.String |
BuiltinFeaturesKey |
"datadistributionmanager.kafka.globalconf.builtin.features" |
public static final java.lang.String |
CheckCrcsKey |
"datadistributionmanager.kafka.globalconf.check.crcs" |
public static final java.lang.String |
ClientIdKey |
"datadistributionmanager.kafka.globalconf.client.id" |
public static final java.lang.String |
ClientRackKey |
"datadistributionmanager.kafka.globalconf.client.rack" |
public static final java.lang.String |
CompressionCodecKey |
"datadistributionmanager.kafka.globalconf.compression.codec" |
public static final java.lang.String |
CompressionLevelKey |
"datadistributionmanager.kafka.topicconf.compression.level" |
public static final java.lang.String |
ConnectionsMaxIdleKey |
"datadistributionmanager.kafka.globalconf.connections.max.idle.ms" |
public static final java.lang.String |
ConsumeCallbackMaxMessagesKey |
"datadistributionmanager.kafka.topicconf.consume.callback.max.messages" |
public static final java.lang.String |
CoordinatorQueryIntervalKey |
"datadistributionmanager.kafka.globalconf.coordinator.query.interval.ms" |
public static final java.lang.String |
DebugKey |
"datadistributionmanager.kafka.globalconf.debug" |
public static final java.lang.String |
DeliveryReportOnlyErrorKey |
"datadistributionmanager.kafka.globalconf.delivery.report.only.error" |
public static final java.lang.String |
DumpMetadataKey |
"datadistributionmanager.kafka.topic_dumpmetadata" |
public static final java.lang.String |
EnableAutoCommitKey |
"datadistributionmanager.kafka.globalconf.enable.auto.commit" |
public static final java.lang.String |
EnableAutoOffsetStoreKey |
"datadistributionmanager.kafka.globalconf.enable.auto.offset.store" |
public static final java.lang.String |
EnableGaplessGuaranteeKey |
"datadistributionmanager.kafka.globalconf.enable.gapless.guarantee" |
public static final java.lang.String |
EnableIdempotenceKey |
"datadistributionmanager.kafka.globalconf.enable.idempotence" |
public static final java.lang.String |
EnablePartitionEofKey |
"datadistributionmanager.kafka.globalconf.enable.partition.eof" |
public static final java.lang.String |
EnableRandomSeedKey |
"datadistributionmanager.kafka.globalconf.enable.random.seed" |
public static final java.lang.String |
EnableSaslOauthbearerUnsecureJwtKey |
"datadistributionmanager.kafka.globalconf.enable.sasl.oauthbearer.unsecure.jwt" |
public static final java.lang.String |
EnableSslCertificateVerificationKey |
"datadistributionmanager.kafka.globalconf.enable.ssl.certificate.verification" |
public static final java.lang.String |
FetchErrorBackoffKey |
"datadistributionmanager.kafka.globalconf.fetch.error.backoff.ms" |
public static final java.lang.String |
FetchMaxBytesKey |
"datadistributionmanager.kafka.globalconf.fetch.max.bytes" |
public static final java.lang.String |
FetchMessageMaxBytesKey |
"datadistributionmanager.kafka.globalconf.fetch.message.max.bytes" |
public static final java.lang.String |
FetchMinBytesKey |
"datadistributionmanager.kafka.globalconf.fetch.min.bytes" |
public static final java.lang.String |
FetchWaitMaxKey |
"datadistributionmanager.kafka.globalconf.fetch.wait.max.ms" |
public static final java.lang.String |
GroupIdKey |
"datadistributionmanager.kafka.globalconf.group.id" |
public static final java.lang.String |
GroupInstanceIdKey |
"datadistributionmanager.kafka.globalconf.group.instance.id" |
public static final java.lang.String |
GroupProtocolTypeKey |
"datadistributionmanager.kafka.globalconf.group.protocol.type" |
public static final java.lang.String |
HeartbeatIntervalKey |
"datadistributionmanager.kafka.globalconf.heartbeat.interval.ms" |
public static final java.lang.String |
IntervalTerminationSignalKey |
"datadistributionmanager.kafka.globalconf.internal.termination.signal" |
public static final java.lang.String |
IsolationLevelKey |
"datadistributionmanager.kafka.globalconf.isolation.level" |
public static final java.lang.String |
LogConnectionCloseKey |
"datadistributionmanager.kafka.globalconf.log.connection.close" |
public static final java.lang.String |
LogLevelKey |
"datadistributionmanager.kafka.globalconf.log_level" |
public static final java.lang.String |
LogQueueKey |
"datadistributionmanager.kafka.globalconf.log.queue" |
public static final java.lang.String |
LogThreadNameKey |
"datadistributionmanager.kafka.globalconf.log.thread.name" |
public static final java.lang.String |
MaxInFlightRequestsPerConnectionKey |
"datadistributionmanager.kafka.globalconf.max.in.flight.requests.per.connection" |
public static final java.lang.String |
MaxPollIntervalKey |
"datadistributionmanager.kafka.globalconf.max.poll.interval.ms" |
public static final java.lang.String |
MessageCopyMaxBytesKey |
"datadistributionmanager.kafka.globalconf.message.copy.max.bytes" |
public static final java.lang.String |
MessageMaxBytesKey |
"datadistributionmanager.kafka.globalconf.message.max.bytes" |
public static final java.lang.String |
MessageSendMaxRetriesKey |
"datadistributionmanager.kafka.globalconf.message.send.max.retries" |
public static final java.lang.String |
MessageTimeoutKey |
"datadistributionmanager.kafka.topicconf.message.timeout.ms" |
public static final java.lang.String |
MetadataMaxAgeKey |
"datadistributionmanager.kafka.globalconf.metadata.max.age.ms" |
public static final java.lang.String |
MetadataRequestTimeoutKey |
"datadistributionmanager.kafka.globalconf.metadata.request.timeout.ms" |
public static final java.lang.String |
PartitionAssignmentStrategyKey |
"datadistributionmanager.kafka.globalconf.partition.assignment.strategy" |
public static final java.lang.String |
PartitionerKey |
"datadistributionmanager.kafka.topicconf.partitioner" |
public static final java.lang.String |
PluginLibraryPathsKey |
"datadistributionmanager.kafka.globalconf.plugin.library.paths" |
public static final java.lang.String |
QueueBufferingBackpressureThresholdKey |
"datadistributionmanager.kafka.globalconf.queue.buffering.backpressure.threshold" |
public static final java.lang.String |
QueueBufferingMaxKbKey |
"datadistributionmanager.kafka.globalconf.queue.buffering.max.kbytes" |
public static final java.lang.String |
QueueBufferingMaxMessagesKey |
"datadistributionmanager.kafka.globalconf.queue.buffering.max.messages" |
public static final java.lang.String |
QueueBufferingMaxMsKey |
"datadistributionmanager.kafka.globalconf.queue.buffering.max.ms" |
public static final java.lang.String |
QueuedMaxMessagesKbKey |
"datadistributionmanager.kafka.globalconf.queued.max.messages.kbytes" |
public static final java.lang.String |
QueuedMinMessagesKey |
"datadistributionmanager.kafka.globalconf.queued.min.messages" |
public static final java.lang.String |
QueueingStrategyKey |
"datadistributionmanager.kafka.topicconf.queuing.strategy" |
public static final java.lang.String |
ReceiveMessageMaxBytesKey |
"datadistributionmanager.kafka.globalconf.receive.message.max.bytes" |
public static final java.lang.String |
ReconnectBackoffKey |
"datadistributionmanager.kafka.globalconf.reconnect.backoff.ms" |
public static final java.lang.String |
ReconnectBackoffMaxKey |
"datadistributionmanager.kafka.globalconf.reconnect.backoff.max.ms" |
public static final java.lang.String |
ReplicationFactorKey |
"datadistributionmanager.kafka.topic_replicationfactor" |
public static final java.lang.String |
RequestRequiredAcksKey |
"datadistributionmanager.kafka.topicconf.request.required.acks" |
public static final java.lang.String |
RequestTimeoutKey |
"datadistributionmanager.kafka.topicconf.request.timeout.ms" |
public static final java.lang.String |
RetryBackoffKey |
"datadistributionmanager.kafka.globalconf.retry.backoff.ms" |
public static final java.lang.String |
SaslKerberosKeytabKey |
"datadistributionmanager.kafka.globalconf.sasl.kerberos.keytab" |
public static final java.lang.String |
SaslKerberosKinitCmdKey |
"datadistributionmanager.kafka.globalconf.sasl.kerberos.kinit.cmd" |
public static final java.lang.String |
SaslKerberosMinTimeBeforeReloginKey |
"datadistributionmanager.kafka.globalconf.sasl.kerberos.min.time.before.relogin" |
public static final java.lang.String |
SaslKerberosPrincipalKey |
"datadistributionmanager.kafka.globalconf.sasl.kerberos.principal" |
public static final java.lang.String |
SaslKerberosServiceNameKey |
"datadistributionmanager.kafka.globalconf.sasl.kerberos.service.name" |
public static final java.lang.String |
SaslMechanismKey |
"datadistributionmanager.kafka.globalconf.sasl.mechanisms" |
public static final java.lang.String |
SaslOauthbearerClientIdKey |
"datadistributionmanager.kafka.globalconf.sasl.oauthbearer.client.id" |
public static final java.lang.String |
SaslOauthbearerClientSecretKey |
"datadistributionmanager.kafka.globalconf.sasl.oauthbearer.client.secret" |
public static final java.lang.String |
SaslOauthbearerConfigKey |
"datadistributionmanager.kafka.globalconf.sasl.oauthbearer.config" |
public static final java.lang.String |
SaslOauthbearerExtensionsKey |
"datadistributionmanager.kafka.globalconf.sasl.oauthbearer.extensions" |
public static final java.lang.String |
SaslOauthbearerMethodKey |
"datadistributionmanager.kafka.globalconf.sasl.oauthbearer.method" |
public static final java.lang.String |
SaslOauthbearerScopeKey |
"datadistributionmanager.kafka.globalconf.sasl.oauthbearer.scope" |
public static final java.lang.String |
SaslOauthbearerTokenEndpointUrlKey |
"datadistributionmanager.kafka.globalconf.sasl.oauthbearer.token.endpoint.url" |
public static final java.lang.String |
SaslPasswordKey |
"datadistributionmanager.kafka.globalconf.sasl.password" |
public static final java.lang.String |
SaslUsernameKey |
"datadistributionmanager.kafka.globalconf.sasl.username" |
public static final java.lang.String |
SecurityProtocolKey |
"datadistributionmanager.kafka.globalconf.security.protocol" |
public static final java.lang.String |
SessionTimeoutKey |
"datadistributionmanager.kafka.globalconf.session.timeout.ms" |
public static final java.lang.String |
SocketConnectionSetupTimeoutKey |
"datadistributionmanager.kafka.globalconf.socket.connection.setup.timeout.ms" |
public static final java.lang.String |
SocketKeepaliveEnableKey |
"datadistributionmanager.kafka.globalconf.socket.keepalive.enable" |
public static final java.lang.String |
SocketMaxFailsKey |
"datadistributionmanager.kafka.globalconf.socket.max.fails" |
public static final java.lang.String |
SocketNagleDisableKey |
"datadistributionmanager.kafka.globalconf.socket.nagle.disable" |
public static final java.lang.String |
SocketReceiveBufferBytesKey |
"datadistributionmanager.kafka.globalconf.socket.receive.buffer.bytes" |
public static final java.lang.String |
SocketSendBufferBytesKey |
"datadistributionmanager.kafka.globalconf.socket.send.buffer.bytes" |
public static final java.lang.String |
SocketTimeoutKey |
"datadistributionmanager.kafka.globalconf.socket.timeout.ms" |
public static final java.lang.String |
SslCACertificateStoresKey |
"datadistributionmanager.kafka.globalconf.ssl.ca.certificate.stores" |
public static final java.lang.String |
SslCAKey |
"datadistributionmanager.kafka.globalconf.ssl_ca" |
public static final java.lang.String |
SslCALocationKey |
"datadistributionmanager.kafka.globalconf.ssl.ca.location" |
public static final java.lang.String |
SslCAPemKey |
"datadistributionmanager.kafka.globalconf.ssl.ca.pem" |
public static final java.lang.String |
SslCertificateKey |
"datadistributionmanager.kafka.globalconf.ssl_certificate" |
public static final java.lang.String |
SslCertificateLocationKey |
"datadistributionmanager.kafka.globalconf.ssl.certificate.location" |
public static final java.lang.String |
SslCertificatePemKey |
"datadistributionmanager.kafka.globalconf.ssl.certificate.pem" |
public static final java.lang.String |
SslCipherSuitesKey |
"datadistributionmanager.kafka.globalconf.ssl.cipher.suites" |
public static final java.lang.String |
SslCrlLocationKey |
"datadistributionmanager.kafka.globalconf.ssl.crl.location" |
public static final java.lang.String |
SslCurvesListKey |
"datadistributionmanager.kafka.globalconf.ssl.curves.list" |
public static final java.lang.String |
SslEndpointIdentificationAlgorithmKey |
"datadistributionmanager.kafka.globalconf.ssl.endpoint.identification.algorithm" |
public static final java.lang.String |
SslEngineIdKey |
"datadistributionmanager.kafka.globalconf.ssl.engine.id" |
public static final java.lang.String |
SslEngineLocationKey |
"datadistributionmanager.kafka.globalconf.ssl.engine.location" |
public static final java.lang.String |
SslKeyKey |
"datadistributionmanager.kafka.globalconf.ssl_key" |
public static final java.lang.String |
SslKeyLocationKey |
"datadistributionmanager.kafka.globalconf.ssl.key.location" |
public static final java.lang.String |
SslKeyPasswordKey |
"datadistributionmanager.kafka.globalconf.ssl.key.password" |
public static final java.lang.String |
SslKeyPemKey |
"datadistributionmanager.kafka.globalconf.ssl.key.pem" |
public static final java.lang.String |
SslKeystoreLocationKey |
"datadistributionmanager.kafka.globalconf.ssl.keystore.location" |
public static final java.lang.String |
SslKeystorePasswordKey |
"datadistributionmanager.kafka.globalconf.ssl.keystore.password" |
public static final java.lang.String |
SslSisalgsListKey |
"datadistributionmanager.kafka.globalconf.ssl.sigalgs.list" |
public static final java.lang.String |
StatisticsIntervalKey |
"datadistributionmanager.kafka.globalconf.statistics.interval.ms" |
public static final java.lang.String |
StickyPartitioningLingerKey |
"datadistributionmanager.kafka.globalconf.sticky.partitioning.linger.ms" |
public static final java.lang.String |
TopicBlackListKey |
"datadistributionmanager.kafka.globalconf.topic.blacklist" |
public static final java.lang.String |
TopicCompressionCodecKey |
"datadistributionmanager.kafka.topicconf.compression.codec" |
public static final java.lang.String |
TopicCreateKey |
"datadistributionmanager.kafka.topic_create" |
public static final java.lang.String |
TopicMetadataPropagationMaxKey |
"datadistributionmanager.kafka.globalconf.topic.metadata.propagation.max.ms" |
public static final java.lang.String |
TopicMetadataRefreshFastIntervalKey |
"datadistributionmanager.kafka.globalconf.topic.metadata.refresh.fast.interval.ms" |
public static final java.lang.String |
TopicMetadataRefreshIntervalKey |
"datadistributionmanager.kafka.globalconf.topic.metadata.refresh.interval.ms" |
public static final java.lang.String |
TopicMetadataRefreshSparseKey |
"datadistributionmanager.kafka.globalconf.topic.metadata.refresh.sparse" |
public static final java.lang.String |
TransactionalIdKey |
"datadistributionmanager.kafka.globalconf.transactional.id" |
public static final java.lang.String |
TransactionTimeoutKey |
"datadistributionmanager.kafka.globalconf.transaction.timeout.ms" |