kafka_demo

package
v1.0.1 Latest Latest
Warning

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

Go to latest
Published: Aug 11, 2020 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Consume added in v1.0.1

func Consume()

func Consume2 added in v1.0.1

func Consume2()

func Produce added in v1.0.1

func Produce(msg []byte) error

Types

type Consumer added in v1.0.1

type Consumer struct {
	// contains filtered or unexported fields
}

func (*Consumer) Cleanup added in v1.0.1

func (consumer *Consumer) Cleanup(session sarama.ConsumerGroupSession) error

func (*Consumer) ConsumeClaim added in v1.0.1

func (consumer *Consumer) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error

func (*Consumer) Setup added in v1.0.1

func (consumer *Consumer) Setup(session sarama.ConsumerGroupSession) error

type ProducerPool

type ProducerPool struct {
	InputQueue  chan []byte
	ProducerNum int
	// contains filtered or unexported fields
}

func (*ProducerPool) Run

func (pp *ProducerPool) Run()

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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