Documentation ¶
Index ¶
- func Install(name string, opts ...manifest.CfgFn) feature.StepFn
- func WithAuthSecret(authSecret string) manifest.CfgFn
- func WithBootstrapServer(bootstrapServer string) manifest.CfgFn
- func WithKafkaChannelMTBroker() manifest.CfgFn
- func WithNumPartitions(numPartitions int32) manifest.CfgFn
- func WithReplicationFactor(replicationFactor int16) manifest.CfgFn
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func WithAuthSecret ¶
func WithBootstrapServer ¶
WithBootstrapServer adds the bootstrap server
func WithKafkaChannelMTBroker ¶ added in v0.36.6
func WithNumPartitions ¶
WithNumPartitions adds the num of partitions
func WithReplicationFactor ¶
WithReplicationFactor adds the replication factor
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.