# README
go-kafka
seperated from go-utils/kafka
# Functions
NewCommitFilter create new CommitFilter.
NewKafkaCliWithGroupID create new kafka consumer.
WithCommitFilterCheckChanSize set commit check channel's size.
WithCommitFilterCheckInterval set commit check interval.
WithCommitFilterCheckNum set commit check num.
# Structs
CommitFilter buffer to lazy commit kafka message.
KafkaCli kafka consumer client.
KafkaCliCfg configuration for kafka message.
KafkaMsg kafka message.
# Type aliases
CommitFilterOptFunc option for CommitFilter.