Config

class kafkaconnect.config.Config(broker_url: str = 'localhost:9092', connect_url: str = 'http://localhost:8083', topic_regex: str = '.*', excluded_topics: str = '', check_interval: int = 15000)

Bases: object

Kafkaconnect application configuration.

Attributes Summary

broker_url The Kafka Broker URL.
check_interval The interval, in milliseconds, to update the connector.
connect_url The Kafka Connect URL.
excluded_topics Comma separated list of topics to exclude from selection.
topic_regex Regex to select topics from Kafka.

Attributes Documentation

broker_url = 'localhost:9092'

The Kafka Broker URL.

check_interval = 15000

The interval, in milliseconds, to update the connector.

Check Kafka for new topics and update the connector configuration.

connect_url = 'http://localhost:8083'

The Kafka Connect URL.

The Kafka Connect REST API is used to manage connectors.

excluded_topics = ''

Comma separated list of topics to exclude from selection.

topic_regex = '.*'

Regex to select topics from Kafka.