File tree Expand file tree Collapse file tree 1 file changed +4
-0
lines changed Expand file tree Collapse file tree 1 file changed +4
-0
lines changed Original file line number Diff line number Diff line change @@ -719,6 +719,8 @@ ActiveSupport::Notifications.subscribe(/.*\.kafka$/) do |*args|
719719end
720720```
721721
722+ All notification events have the ` client_id ` key in the payload, referring to the Kafka client id.
723+
722724#### Producer Notifications
723725
724726* ` produce_message.producer.kafka ` is sent whenever a message is produced to a buffer. It includes the following payload:
735737
736738#### Consumer Notifications
737739
740+ All notifications have ` group_id ` in the payload, referring to the Kafka consumer group id.
741+
738742* ` process_message.consumer.kafka ` is sent whenever a message is processed by a consumer. It includes the following payload:
739743 * ` value ` is the message value.
740744 * ` key ` is the message key.
You can’t perform that action at this time.
0 commit comments