<div dir="ltr"><span style="color:rgb(51,51,51);font-family:Helvetica,arial,freesans,clean,sans-serif,'Segoe UI Emoji','Segoe UI Symbol';font-size:14px;line-height:23px">Thanks for write_kafka module. I have actually developed a similar plugin recently and wanted to contribute it soon! </span><div>
<span style="color:rgb(51,51,51);font-family:Helvetica,arial,freesans,clean,sans-serif,'Segoe UI Emoji','Segoe UI Symbol';font-size:14px;line-height:23px"><br></span></div><div><font color="#333333" face="Helvetica, arial, freesans, clean, sans-serif, Segoe UI Emoji, Segoe UI Symbol"><span style="font-size:14px;line-height:23px">Today I looked at this module to somehow compare and contrast with my code but it is not working with the following config! </span></font></div>
<div><p style="margin:0px;font-size:12px;font-family:'Lucida Grande'">LoadPlugin write_kafka</p><p style="margin:0px;font-size:12px;font-family:'Lucida Grande'"><Plugin write_kafka></p><p style="margin:0px;font-size:12px;font-family:'Lucida Grande'">
Property "metadata.broker.list" "<our kafka broker url>:9092"<br></p><p style="margin:0px;font-size:12px;font-family:'Lucida Grande'"><Topic "collectd-kafka-4"></p><p style="margin:0px;font-size:12px;font-family:'Lucida Grande'">
</Topic>   </p><p style="margin:0px;font-size:12px;font-family:'Lucida Grande'"></Plugin></p></div><div><span style="color:rgb(51,51,51);font-family:Helvetica,arial,freesans,clean,sans-serif,'Segoe UI Emoji','Segoe UI Symbol';font-size:14px;line-height:23px"><br>
</span></div><div><span style="color:rgb(51,51,51);font-family:Helvetica,arial,freesans,clean,sans-serif,'Segoe UI Emoji','Segoe UI Symbol';font-size:14px;line-height:23px">Also, if you specify the Format the way that the man page says, you get the following error:</span></div>
<div><p style="margin:0px;font-size:11px;font-family:Menlo;background-color:rgb(254,244,156)">collectd(5675,0x7fff7601c310) malloc: *** error for object 0x21: pointer being freed was not allocated</p>
<p style="margin:0px;font-size:11px;font-family:Menlo;background-color:rgb(254,244,156)">*** set a breakpoint in malloc_error_break to debug</p>
<p style="margin:0px;font-size:11px;font-family:Menlo;background-color:rgb(254,244,156)">Abort trap: 6</p></div><div><br></div><div><div><span style="color:rgb(51,51,51);font-family:Helvetica,arial,freesans,clean,sans-serif,'Segoe UI Emoji','Segoe UI Symbol';font-size:14px;line-height:23px">I solved this problem by putting the default to Command (added </span><span style="background-color:rgb(254,244,156);font-family:Menlo;font-size:11px">ctx->format = KAFKA_FORMAT_COMMAND;</span><span style="color:rgb(51,51,51);font-family:Helvetica,arial,freesans,clean,sans-serif,'Segoe UI Emoji','Segoe UI Symbol';font-size:14px;line-height:23px">) at line 98. Then, I was able to see that the code is calling </span><span style="background-color:rgb(254,244,156);font-family:Menlo;font-size:11px">rd_kafka_produce()</span><span style="font-size:14px;line-height:23px;color:rgb(51,51,51);font-family:Helvetica,arial,freesans,clean,sans-serif,'Segoe UI Emoji','Segoe UI Symbol'"> correctly which is great, but I don't see anything written on the Kafka side to my topic! Am I missing anything? I am able to use my own write_kafka to send collectd messages to Kafka, so I am sure about my Kafka configuration.</span></div>
<div><font color="#333333" face="Helvetica, arial, freesans, clean, sans-serif, Segoe UI Emoji, Segoe UI Symbol"><span style="font-size:14px;line-height:23px"><br></span></font></div><div><span style="color:rgb(51,51,51);font-family:Helvetica,arial,freesans,clean,sans-serif,'Segoe UI Emoji','Segoe UI Symbol';font-size:14px;line-height:23px">Thanks again for doing this. This is very useful,</span><br>
</div></div><div><span style="color:rgb(51,51,51);font-family:Helvetica,arial,freesans,clean,sans-serif,'Segoe UI Emoji','Segoe UI Symbol';font-size:14px;line-height:23px">Babak</span></div></div>