kafkac

Documentation

Index

• Variables
• func ExampleConsume()
• func ExampleConsumePro()
• func ExampleSendMessage(message ExampleMessage)
• func InitStartConsumer(address []string, groupID string) (sarama.ConsumerGroup, error)
• func InitStartProducer(address []string) (sarama.SyncProducer, error)
• type ExampleMessage

Variables

var (
	ExampleProducerClient    sarama.SyncProducer
	ExampleConsumerClient    sarama.ConsumerGroup
	ExampleConsumerClientPro sarama.ConsumerGroup
	Topic                    = "CcCode"
)

Functions

func ExampleConsume

func ExampleConsume()

func ExampleConsumePro

func ExampleConsumePro()

func ExampleSendMessage

func ExampleSendMessage(message ExampleMessage)

func InitStartConsumer

func InitStartConsumer(address []string, groupID string) (sarama.ConsumerGroup, error)

InitStartConsumer 传不同的groupID

func InitStartProducer

func InitStartProducer(address []string) (sarama.SyncProducer, error)

Types

type ExampleMessage

type ExampleMessage struct {
	Id   int64
	Name string
}