File tree 1 file changed +3
-3
lines changed
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)
288
288
}
289
289
290
290
# This gets us the write rate.
291
- increment ( "producer.produce.messages" , tags : tags . merge ( topic : topic ) )
291
+ increment ( "producer.produce.messages" , tags : tags )
292
292
293
293
# 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 )
295
295
296
296
# 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 )
298
298
299
299
# This gets us the avg/max buffer size per producer.
300
300
histogram ( "producer.buffer.size" , buffer_size , tags : tags )
You can’t perform that action at this time.
0 commit comments