class Karafka::Persistence::Client

def self.write(client)

Returns:
  • (Karafka::Connection::Client) - persisted messages consumer client

Parameters:
  • client (Karafka::Connection::Client) -- messages consumer client of 
def self.write(client)
  Thread.current[PERSISTENCE_SCOPE] = client
end