基础知识
指南
参考资料
系统测试
资源
提交记录
default_args
consumer_logger
t0
test_run
load_connections()
load_connections
producer_function()
producer_function
consumer_function(message[, prefix])
consumer_function
consumer_function_batch(messages[, prefix])
consumer_function_batch
await_function(message)
await_function
hello_kafka()
hello_kafka
此条目是否有帮助?
consumer_function()
consumer_function_batch()
await_function()