Kafka

Category: Queue Status: base

Connects to an Apache Kafka message broker. Supports browsing topics, creating/deleting topics, and streaming messages.

Connection Settings

Field	Default	Description
host	localhost	Broker hostname or IP
port	9092	Broker port
url	(empty)	Full broker URL (overrides host/port)

Authentication

No built-in credentials in the default configuration. For SASL/SSL, configure via the connection URL or broker settings.

Supported Actions

• create_topic — create a new Kafka topic
• delete_topic — remove a topic
• purge_topic — clear all messages from a topic
• search_by_name — search topics by name
• duplicate — duplicate a topic configuration
• transfer_between_connectors — move data between connectors
• stream_table / start_stream / stop_stream — consume and stream topic messages in real time

External Links

• https://kafka.apache.org/documentation/