Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
A client providing broker APIs
func (*Client) AlterConfigsMethod ¶
The alter configs method that should be used (auto, incremental, non-incremental)
type ClientConfig ¶
type ClientConfig struct { SeedBrokers []string `json:"seedBrokers,omitempty"` TLS *tlsConfig `json:"tls,omitempty"` SASL *saslConfig `json:"sasl,omitempty"` // Set the maximum Kafka version to try (e.g. '0.8.0', '2.3.0') AsVersion string `json:"asVersion,omitempty"` // Underlying Kafka client log-level (none, error, warn, info, debug) LogLevel string `json:"logLevel,omitempty"` // Timeout in milliseconds to be used by requests with timeouts TimeoutMs int32 `json:"timeoutMs,omitempty"` // The alter configs method that should be used (auto, incremental, non-incremental) AlterConfigsMethod string `json:"alterConfigsMethod,omitempty"` }
Client configuration
Click to show internal directories.
Click to hide internal directories.