Skip to content

Commit 3b85890

Browse files
committed
All consumer parameters are logged when the consumer is starting
1 parent 47fb4ab commit 3b85890

File tree

1 file changed

+12
-0
lines changed

1 file changed

+12
-0
lines changed

lib/consumer/postgres/postgres.rb

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -21,13 +21,25 @@ def starting
2121
logger.info(tag: :*) { "Correlation: #{correlation}" }
2222
end
2323

24+
unless identifier.nil?
25+
logger.info(tag: :*) { "Identifier: #{identifier}" }
26+
end
27+
2428
unless group_member.nil? && group_size.nil?
2529
logger.info(tag: :*) { "Group Member: #{group_member.inspect}, Group Size: #{group_size.inspect}" }
2630
end
2731

2832
unless condition.nil?
2933
logger.info(tag: :*) { "Condition: #{condition}" }
3034
end
35+
36+
unless poll_interval_milliseconds.nil?
37+
logger.info(tag: :*) { "Poll Interval Milliseconds: #{poll_interval_milliseconds}" }
38+
end
39+
40+
unless position_update_interval.nil?
41+
logger.info(tag: :*) { "Position Update Interval: #{position_update_interval}" }
42+
end
3143
end
3244

3345
def configure(batch_size: nil, settings: nil, correlation: nil, group_member: nil, group_size: nil, condition: nil)

0 commit comments

Comments
 (0)