Closed LeeC20 closed 10 months ago
kafka的有人已经实现过了 在 test_frame/test_custom_broker/kafka_sasl_plain_as_broker.py 里面, funboost框架的扩展中间件或者修改逻辑,用户是无需改动源码的呢.你可以看4.21章节的介绍.
最重要的就是调用 register_custom_broker ,就可以注册自己的中间件方式到框架了.这种扩展用户无需修改funboost框架源码.
30.8版本恢复成了conn操作命令
和啦,用户可以使用密码连接kafka了.
增加了SASL kafka的连接方式, 还原了杀死进程的方式