Module: Rdkafka::Callbacks

Defined in:

lib/rdkafka/callbacks.rb

Constant Summary

BackgroundEventCallbackFunction =

FFI Function used for Create Topic and Delete Topic callbacks

FFI::Function.new(
    :void, [:pointer, :pointer, :pointer]
) do |client_ptr, event_ptr, opaque_ptr|
  BackgroundEventCallback.call(client_ptr, event_ptr, opaque_ptr)
end

DeliveryCallbackFunction =

FFI Function used for Message Delivery callbacks

FFI::Function.new(
    :void, [:pointer, :pointer, :pointer]
) do |client_ptr, message_ptr, opaque_ptr|
  DeliveryCallback.call(client_ptr, message_ptr, opaque_ptr)
end