kafka_topic

func ACLCreate ¶

func ACLCreate(ctx context.Context, d *schema.ResourceData, meta interface{}) diag.Diagnostics

func ACLDelete ¶

func ACLDelete(ctx context.Context, d *schema.ResourceData, meta interface{}) diag.Diagnostics

func ACLRead ¶

func ACLRead(ctx context.Context, d *schema.ResourceData, meta interface{}) diag.Diagnostics

func Provider ¶

func Provider() *schema.Provider

func ResourceKafkaACL ¶

func ResourceKafkaACL() *schema.Resource

func ResourceKafkaTopic ¶

func ResourceKafkaTopic() *schema.Resource

func SchemaKafkaTopicConfigEntries ¶

func SchemaKafkaTopicConfigEntries() map[string]*schema.Schema

func TopicCreate ¶

func TopicCreate(ctx context.Context, d *schema.ResourceData, meta interface{}) diag.Diagnostics

--create Create a new topic. --delete Delete a topic --delete-config <String: name> A topic configuration override to be

removed for an existing topic (see
the list of configurations under the
--config option). Not supported with
the --bootstrap-server option.

--describe List details for the given topics. --disable-rack-aware Disable rack aware replica assignment --exclude-internal exclude internal topics when running

list or describe command. The
internal topics will be listed by
default

--force Suppress console prompts --help Print usage information. --if-exists if set when altering or deleting or

describing topics, the action will
only execute if the topic exists.

--if-not-exists if set when creating topics, the

action will only execute if the
topic does not already exist.

--list List all available topics. --partitions <Integer: # of partitions> The number of partitions for the topic

being created or altered (WARNING:
If partitions are increased for a
topic that has a key, the partition
logic or ordering of the messages
will be affected). If not supplied
for create, defaults to the cluster
default.

--replica-assignment <String: A list of manual partition-to-broker

broker_id_for_part1_replica1 :           assignments for the topic being
broker_id_for_part1_replica2 ,           created or altered.
broker_id_for_part2_replica1 :
broker_id_for_part2_replica2 , ...>

--replication-factor <Integer: The replication factor for each

replication factor>                      partition in the topic being
                                         created. If not supplied, defaults
                                         to the cluster default.

--topic <String: topic> The topic to create, alter, describe

or delete. It also accepts a regular
expression, except for --create
option. Put topic name in double
quotes and use the '\' prefix to
escape regular expression symbols; e.
g. "test\.topic".

--topics-with-overrides if set when describing topics, only

show topics that have overridden
configs

--unavailable-partitions if set when describing topics, only

show partitions whose leader is not
available

--under-min-isr-partitions if set when describing topics, only

show partitions whose isr count is
less than the configured minimum.
Not supported with the --zookeeper
option.

--under-replicated-partitions if set when describing topics, only

show under replicated partitions

--version Display Kafka version. --zookeeper <String: hosts> DEPRECATED, The connection string for

the zookeeper connection in the form
host:port. Multiple hosts can be
given to allow fail-over.

func TopicDelete ¶

func TopicDelete(ctx context.Context, d *schema.ResourceData, meta interface{}) diag.Diagnostics

func ClusterCreate(ctx context.Context, d *schema.ResourceData, meta interface{}) diag.Diagnostics {

func TopicRead ¶

func TopicRead(ctx context.Context, d *schema.ResourceData, meta interface{}) diag.Diagnostics

func ValidateKafkaCleanupPolicy ¶

func ValidateKafkaCleanupPolicy(val interface{}, key string) (warns []string, errs []error)

func ValidateKafkaCompressionType ¶

func ValidateKafkaCompressionType(val interface{}, key string) (warns []string, errs []error)

func ValidateMessageFormatVersion ¶

func ValidateMessageFormatVersion(val interface{}, key string) (warns []string, errs []error)

func ValidateMessageTimestampType ¶

func ValidateMessageTimestampType(val interface{}, key string) (warns []string, errs []error)

func ValidateOperationType ¶

func ValidateOperationType(val interface{}, key string) (warns []string, errs []error)

func ValidatePermissionType ¶

func ValidatePermissionType(val interface{}, key string) (warns []string, errs []error)

func ValidateResourcePatternType ¶

func ValidateResourcePatternType(val interface{}, key string) (warns []string, errs []error)

func ValidateResourceType ¶

func ValidateResourceType(val interface{}, key string) (warns []string, errs []error)