class Kafka::Producer::DeliveryReport

Defined in:

kafka/producer/delivery_report.cr

Class Method Summary

Class Method Detail

def self.callback #

Returns a callback to be used when a message is delivered to a broker.

This logs the message payload that was delivered. The message arrives by pointer (see the conf_set_dr_msg_cb binding); the payload is not NUL-terminated, so the string is built with the message length. When err is set, librdkafka reuses the payload field for the error string.


[View source]