File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -288,13 +288,13 @@ def produce_message(event)
288288 }
289289
290290 # This gets us the write rate.
291- increment ( "producer.produce.messages" , tags : tags . merge ( topic : topic ) )
291+ increment ( "producer.produce.messages" , tags : tags )
292292
293293 # Information about typical/average/95p message size.
294- histogram ( "producer.produce.message_size" , message_size , tags : tags . merge ( topic : topic ) )
294+ histogram ( "producer.produce.message_size" , message_size , tags : tags )
295295
296296 # Aggregate message size.
297- count ( "producer.produce.message_size.sum" , message_size , tags : tags . merge ( topic : topic ) )
297+ count ( "producer.produce.message_size.sum" , message_size , tags : tags )
298298
299299 # This gets us the avg/max buffer size per producer.
300300 histogram ( "producer.buffer.size" , buffer_size , tags : tags )
You can’t perform that action at this time.
0 commit comments