Apache Kafka TopicList

Apache Kafka TopicList
Certified
List Kafka topics

Lists topic names visible to the AdminClient. Internal topics (e.g. __consumer_offsets) are excluded by default.

yaml
type: io.kestra.plugin.kafka.TopicList

Examples

List all topics on a cluster

yaml
id: kafka_topic_list
namespace: company.team

tasks:
  - id: list_topics
    type: io.kestra.plugin.kafka.TopicList
    properties:
      bootstrap.servers: localhost:9092

Properties

properties *object

Kafka AdminClient properties

Must include bootstrap.servers; accepts any Kafka AdminClient config. Provide base64-encoded content for ssl.keystore.location and ssl.truststore.location when using SSL.

includeInternal booleanstring

Defaultfalse

Include internal topics

Defaults to false.

pluginDefaultsRef string

Reference (ref) of the pluginDefaults to apply to this task.

timeout string

DefaultPT30S

AdminClient call timeout

Maximum duration to wait for each AdminClient operation to complete before failing the task. Defaults to PT30S (30 seconds).

Outputs

topics array

SubTypestring

Topic names

Liquibase

Tasks that run Liquibase change management commands.

Data

PostgreSQL

Tasks that connect to PostgreSQL via JDBC to run queries and loads.

Data

Apache Kafka TopicListCertifiedList Kafka topics

Apache Kafka TopicList

More Plugins in this Category

Liquibase

PostgreSQL

Apache Kafka TopicList
Certified
List Kafka topics