broker

package
v0.39.4 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 22, 2024 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Install

func Install(name string, opts ...manifest.CfgFn) feature.StepFn

func WithAuthSecret

func WithAuthSecret(authSecret string) manifest.CfgFn

func WithBootstrapServer

func WithBootstrapServer(bootstrapServer string) manifest.CfgFn

WithBootstrapServer adds the bootstrap server

func WithKafkaChannelMTBroker added in v0.36.6

func WithKafkaChannelMTBroker() manifest.CfgFn

func WithNumPartitions

func WithNumPartitions(numPartitions int32) manifest.CfgFn

WithNumPartitions adds the num of partitions

func WithReplicationFactor

func WithReplicationFactor(replicationFactor int16) manifest.CfgFn

WithReplicationFactor adds the replication factor

Types

This section is empty.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL