TopicConfig

TopicConfig are the keys for a topic-level configuration (and override cluster-wide defaults with log. prefix).

import org.apache.kafka.common.config.TopicConfig
assert(TopicConfig.CLEANUP_POLICY_CONFIG == "cleanup.policy")
Table 1. Keys
Name Description

cleanup.policy

Used when:

  • LogConfig is requested for LogConfig.CleanupPolicyProp

  • (Kafka Streams) RepartitionTopicConfig is requested for REPARTITION_TOPIC_DEFAULT_OVERRIDES

  • (Kafka Streams) UnwindowedChangelogTopicConfig is requested for UNWINDOWED_STORE_CHANGELOG_TOPIC_DEFAULT_OVERRIDES

  • (Kafka Streams) WindowedChangelogTopicConfig is requested for WINDOWED_STORE_CHANGELOG_TOPIC_DEFAULT_OVERRIDES

flush.messages

flush.ms

index.interval.bytes

retention.bytes

retention.ms

segment.bytes

Used when:

  • (Kafka Streams) StreamsConfig is requested to getMainConsumerConfigs

  • (Kafka Streams) RepartitionTopicConfig is requested for REPARTITION_TOPIC_DEFAULT_OVERRIDES

segment.index.bytes

segment.jitter.ms

segment.ms

results matching ""

    No results matching ""