@@ -13,33 +13,26 @@ def self.included(cls)
13
13
end
14
14
15
15
def starting
16
- unless batch_size . nil?
17
- logger . info ( tag : :* ) { "Batch Size: #{ batch_size } " }
18
- end
19
-
20
- unless correlation . nil?
21
- logger . info ( tag : :* ) { "Correlation: #{ correlation } " }
22
- end
23
-
24
- unless identifier . nil?
25
- logger . info ( tag : :* ) { "Identifier: #{ identifier } " }
26
- end
16
+ ## unless batch_size.nil?
17
+ ## logger.info(tag: :*) { "Batch Size: #{batch_size.inspect}" }
18
+ ## end
19
+ logger . debug ( tag : :* ) { "Batch Size: #{ batch_size . inspect } " }
27
20
28
- unless group_member . nil? && group_size . nil?
29
- logger . info ( tag : :* ) { "Group Member: #{ group_member . inspect } , Group Size: #{ group_size . inspect } " }
30
- end
21
+ ## unless correlation.nil?
22
+ ## logger.info(tag: :*) { "Correlation: #{correlation.inspect}" }
23
+ ## end
24
+ logger . debug ( tag : :* ) { "Correlation: #{ correlation . inspect } " }
31
25
32
- unless condition . nil?
33
- logger . info ( tag : :* ) { "Condition: #{ condition } " }
34
- end
26
+ ## unless group_member.nil? && group_size.nil?
27
+ ## logger.info(tag: :*) { "Group Member: #{group_member.inspect}, Group Size: #{group_size.inspect}" }
28
+ ## end
29
+ logger . debug ( tag : :* ) { "Group Member: #{ group_member . inspect } " }
30
+ logger . debug ( tag : :* ) { "Group Size: #{ group_size . inspect } " }
35
31
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
32
+ ## unless condition.nil?
33
+ ## logger.info(tag: :*) { "Condition: #{condition.inspect}" }
34
+ ## end
35
+ logger . debug ( tag : :* ) { "Condition: #{ condition . inspect } " }
43
36
44
37
if identifier . nil? && !group_member . nil? && !group_size . nil?
45
38
raise Identifier ::Error , 'Identifier must not be omitted when the consumer is a member of a group'
0 commit comments