kafka

Documentation

Overview

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.