Skip to content

Commit a0bbaf8

Browse files
authored
Update README with new instrumentation hooks
1 parent 0b0ed87 commit a0bbaf8

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

README.md

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -743,12 +743,16 @@ end
743743
* `offset` is the message's offset within the topic partition.
744744
* `offset_lag` is the number of messages within the topic partition that have not yet been consumed.
745745

746+
* `start_process_message.consumer.kafka` is sent before `process_message.consumer.kafka`, and contains the same payload. It is delivered _before_ the message is processed, rather than _after_.
747+
746748
* `process_batch.consumer.kafka` is sent whenever a message batch is processed by a consumer. It includes the following payload:
747749
* `message_count` is the number of messages in the batch.
748750
* `topic` is the topic that the message batch was consumed from.
749751
* `partition` is the topic partition that the message batch was consumed from.
750752
* `highwater_mark_offset` is the message batch's highest offset within the topic partition.
751-
* `offset_lag` is the number of messages within the topic partition that have not yet been consumed.
753+
* `offset_lag` is the number of messages within the topic partition that have not yet been consumed.
754+
755+
* `start_process_batch.consumer.kafka` is sent before `process_batch.consumer.kafka`, and contains the same payload. It is delivered _before_ the batch is processed, rather than _after_.
752756

753757
* `join_group.consumer.kafka` is sent whenever a consumer joins a consumer group. It includes the following payload:
754758
* `group_id` is the consumer group id.

0 commit comments

Comments
 (0)