Lightning.Workflows.Triggers.KafkaConfiguration (Lightning v2.13.5)

View Source

Configuration of Kafka Triggers.

Summary

Functions

apply_hosts_string(changeset)

apply_topics_string(changeset)

changeset(kafka_configuration, attrs)

generate_hosts_string(changeset)

generate_topics_string(changeset)

sasl_types()

set_group_id_if_required(changeset)

validate_initial_offset_reset_policy(changeset)

validate_sasl_credentials(changeset)