module Karafka::Connection::ApiAdapter

def mark_message_as_processed(params)

Other tags:
    Note: - When default empty topic mapper is used, no need for any conversion as the

Returns:
  • (Array) - array with all the details needed by ruby-kafka to mark message

Parameters:
  • params (Karafka::Params::Params) -- params instance 
def mark_message_as_processed(params)
  # Majority of non heroku users don't use custom topic mappers. No need to change
  # anything when it is a default mapper that does not change anything
  return [params] if Karafka::App.config.topic_mapper == Karafka::Routing::TopicMapper
  # @note We don't use tap as it is around 13% slower than non-dup version
  dupped = params.dup
  dupped['topic'] = Karafka::App.config.topic_mapper.outgoing(params.topic)
  [dupped]
end