kafka

package
v0.32.0 Latest Latest
Warning

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

Go to latest
Published: Jul 21, 2024 License: MIT Imports: 5 Imported by: 0

Documentation

Overview

Package kafka exposes Kafka and Zookeeper containers.

Index

Constants

View Source
const (
	// KafkaServiceName is the advertised name of the Kafka service.
	KafkaServiceName = "kafka"
	// ZookeeperServiceName is the advertised name of the Zookeeper service.
	ZookeeperServiceName = "zookeeper"
)

Variables

This section is empty.

Functions

func NewComponent

func NewComponent(session *docker.Session, opts ...docker.SimpleContainerOptionFunc) *docker.SimpleComponent

NewComponent creates a new Redis component.

func WithTopics

func WithTopics(topics ...string) docker.SimpleContainerOptionFunc

WithTopics sets topics in the kafka container config. E.g. MyTopic:1:1:compact.

Types

This section is empty.

Jump to

Keyboard shortcuts

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