Documentation
¶
Index ¶
- func ACLCreate(ctx context.Context, d *schema.ResourceData, meta interface{}) diag.Diagnostics
- func ACLDelete(ctx context.Context, d *schema.ResourceData, meta interface{}) diag.Diagnostics
- func ACLRead(ctx context.Context, d *schema.ResourceData, meta interface{}) diag.Diagnostics
- func Provider() *schema.Provider
- func ResourceKafkaACL() *schema.Resource
- func ResourceKafkaTopic() *schema.Resource
- func SchemaKafkaTopicConfigEntries() map[string]*schema.Schema
- func TopicCreate(ctx context.Context, d *schema.ResourceData, meta interface{}) diag.Diagnostics
- func TopicDelete(ctx context.Context, d *schema.ResourceData, meta interface{}) diag.Diagnostics
- func TopicRead(ctx context.Context, d *schema.ResourceData, meta interface{}) diag.Diagnostics
- func ValidateKafkaCleanupPolicy(val interface{}, key string) (warns []string, errs []error)
- func ValidateKafkaCompressionType(val interface{}, key string) (warns []string, errs []error)
- func ValidateMessageFormatVersion(val interface{}, key string) (warns []string, errs []error)
- func ValidateMessageTimestampType(val interface{}, key string) (warns []string, errs []error)
- func ValidateOperationType(val interface{}, key string) (warns []string, errs []error)
- func ValidatePermissionType(val interface{}, key string) (warns []string, errs []error)
- func ValidateResourcePatternType(val interface{}, key string) (warns []string, errs []error)
- func ValidateResourceType(val interface{}, key string) (warns []string, errs []error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
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 ResourceKafkaACL ¶
func ResourceKafkaTopic ¶
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 ValidateOperationType ¶
func ValidatePermissionType ¶
func ValidateResourceType ¶
Types ¶
This section is empty.
Source Files