From f5cc5b44541ead15bcba893f301f865d6a46202d Mon Sep 17 00:00:00 2001 From: Pascal Schmid Date: Sat, 19 Feb 2022 14:19:35 +0100 Subject: [PATCH] Log consumer_group offset --- lib/consumer_offsets_consumer_group.ex | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/lib/consumer_offsets_consumer_group.ex b/lib/consumer_offsets_consumer_group.ex index 11f3cae..003a9f8 100644 --- a/lib/consumer_offsets_consumer_group.ex +++ b/lib/consumer_offsets_consumer_group.ex @@ -7,9 +7,9 @@ defmodule ConsumerOffsetsGenConsumer do def handle_message_set(message_set, state) do for %Message{key: key, offset: offset} <- message_set do - Logger.info(fn -> "offset: " <> inspect(offset) end) - consumer_group = get_consumer_group(key) + + Logger.info("consumer_group '#{consumer_group}' has offset '#{offset}'}") end {:async_commit, state}