Crate simple_kafka

Source

Modules§

kafka_init
kafka 初始化生产者和消费者
kafka_producer
提供一个生产者，发送 kafka 消息使用

Structs§

KafkaConfig
KafkaError
KafkaMessage

Functions§

message_handler
consumer 消费消息的测试方法