Sha256: 4f443ec86a1a93a7d32ac84332e05b38a21e99b94d0eab1963d38edfd7bc0d86
Contents?: true
Size: 375 Bytes
Versions: 12
Compression:
Stored size: 375 Bytes
Contents
# frozen_string_literal: true
# Example consumer that prints messages payloads
class ExampleConsumer < ApplicationConsumer
def consume
messages.each { |message| puts message.payload }
end
# Run anything upon partition being revoked
# def on_revoked
# end
# Define here any teardown things you want when Karafka server stops
# def on_shutdown
# end
end
Version data entries
12 entries across 12 versions & 1 rubygems