liupanfeng
liupanfeng
` Configuration config = { { "metadata.broker.list", kafka_servers} }; Producer pp(config); MessageBuilder builder("***"); builder.partition(8); builder.payload("1999"); pp.produce(builder); pp.flush(); ` my code is like this. producer success. consumer got one message. but...
 配置完成后成功使用了两天左右,之后就一直报这个错误。 我上次提问的时候作者让复制错误栈,,可以请问一下怎么复制吗? 这个插件比其他的好用很多,求修复。