kafka

Documentation

Index

• func KafkaClose(kafkaState utils.KafkaState, end, ended chan bool) func()
• func KafkaRoutine(kafkaState utils.KafkaState, protoCodec *codec.ProtoCodec, ...)

Functions

func KafkaClose

func KafkaClose(kafkaState utils.KafkaState, end, ended chan bool) func()

KafkaClose: closes all kafka connections

func KafkaRoutine

func KafkaRoutine(kafkaState utils.KafkaState, protoCodec *codec.ProtoCodec, chain *relayer.Chain, ethereumClient *ethclient.Client, end, ended chan bool)

KafkaRoutine : starts kafka in a separate goRoutine, consumers will each start in different go routines no need to store any db, producers and consumers are inside kafkaState struct. use kafka.ProducerDeliverMessage() -> to produce message use kafka.TopicConsumer -> to consume messages.