package kafka

import "github.com/apache/beam/sdks/v2/go/test/integration/io/xlang/kafka"

Package kafka contains integration tests for cross-language Kafka IO transforms.

Index ¶

• func ReadPipeline(expansionAddr, bootstrapAddr, topic string, inputs []int) *beam.Pipeline
• func WritePipeline(expansionAddr, bootstrapAddr, topic string, inputs []int) *beam.Pipeline

Functions ¶

func ReadPipeline ¶

func ReadPipeline(expansionAddr, bootstrapAddr, topic string, inputs []int) *beam.Pipeline

ReadPipeline creates a pipeline that reads ints from Kafka and asserts that they match a given slice of ints. This reads a number of records equal to the length of the given slice.

func WritePipeline ¶

func WritePipeline(expansionAddr, bootstrapAddr, topic string, inputs []int) *beam.Pipeline

WritePipeline creates a pipeline that writes a given slice of ints to Kafka.

Source Files ¶

cluster_unix.go jar.go kafka.go