Skip to content

Commit de66d87

Browse files
(DOCSP-25294) Port Source Metrics (#21)
1 parent f933c53 commit de66d87

File tree

1 file changed

+227
-12
lines changed

1 file changed

+227
-12
lines changed

source/monitoring-and-logging.txt

Lines changed: 227 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -15,11 +15,11 @@ Monitoring and Logging
1515

1616

1717

18-
Sink Connector JMX Metrics
19-
--------------------------
18+
Available Metrics
19+
-----------------
2020

21-
Use the attributes in the following table to monitor the behavior of your sink
22-
connector through {+jmx-long+} (JMX):
21+
Use the attributes in the tables in this section to monitor the behavior of your source and
22+
sink connectors through {+jmx-long+} (JMX).
2323

2424
.. tip:: JMX Attributes
2525

@@ -28,6 +28,9 @@ connector through {+jmx-long+} (JMX):
2828
`Standard MBeans Tutorial <https://docs.oracle.com/javase/tutorial/jmx/mbeans/standard.html>`__
2929
from Oracle.
3030

31+
Sink Connector JMX Metrics
32+
~~~~~~~~~~~~~~~~~~~~~~~~~~
33+
3134
.. list-table::
3235
:header-rows: 1
3336
:widths: 40 60
@@ -53,11 +56,11 @@ connector through {+jmx-long+} (JMX):
5356
of the last record the task received.
5457

5558
* - **in-task-put**
56-
- The total number of times the Kafka Connect framework executed the
59+
- The total number of times the {+kafka-connect+} framework executed the
5760
``put()`` method of the MongoDB sink task.
5861

5962
* - **in-task-put-duration**
60-
- The total number of milliseconds the Kafka Connect framework spent
63+
- The total number of milliseconds the {+kafka-connect+} framework spent
6164
executing the ``put()`` method of a MongoDB sink task.
6265

6366
* - **in-task-put-duration-over-1-ms**
@@ -81,7 +84,7 @@ connector through {+jmx-long+} (JMX):
8184
with a duration that exceeded 10000 milliseconds.
8285

8386
* - **in-connect-framework**
84-
- The total number of times code in the Kafka Connect framework
87+
- The total number of times code in the {+kafka-connect+} framework
8588
executed after the first invocation of the ``put()`` method of the
8689
MongoDB sink task.
8790

@@ -92,23 +95,23 @@ connector through {+jmx-long+} (JMX):
9295
executing code in the MongoDB sink task towards the total.
9396

9497
* - **in-connect-framework-duration-over-1-ms**
95-
- The total number of times code in the Kafka Connect framework
98+
- The total number of times code in the {+kafka-connect+} framework
9699
executed for a duration that exceeded 1 millisecond.
97100

98101
* - **in-connect-framework-duration-over-10-ms**
99-
- The total number of times code in the Kafka Connect framework
102+
- The total number of times code in the {+kafka-connect+} framework
100103
executed for a duration that exceeded 10 milliseconds.
101104

102105
* - **in-connect-framework-duration-over-100-ms**
103-
- The total number of times code in the Kafka Connect framework
106+
- The total number of times code in the {+kafka-connect+} framework
104107
executed for a duration that exceeded 100 milliseconds.
105108

106109
* - **in-connect-framework-duration-over-1000-ms**
107-
- The total number of times code in the Kafka Connect framework executed
110+
- The total number of times code in the {+kafka-connect+} framework executed
108111
for a duration that exceeded 1000 milliseconds.
109112

110113
* - **in-connect-framework-duration-over-10000-ms**
111-
- The total number of times code in the Kafka Connect framework executed
114+
- The total number of times code in the {+kafka-connect+} framework executed
112115
for a duration that exceeded 10000 milliseconds.
113116

114117
* - **processing-phases**
@@ -196,3 +199,215 @@ connector through {+jmx-long+} (JMX):
196199
* - **batch-writes-failed-duration-over-10000-ms**
197200
- The total number of failed batch writes attempted by the MongoDB sink
198201
task with a duration that exceeded 10000 milliseconds.
202+
203+
Source Connector JMX Metrics
204+
~~~~~~~~~~~~~~~~~~~~~~~~~~~~
205+
206+
.. list-table::
207+
:header-rows: 1
208+
:widths: 40 60
209+
210+
* - Attribute Name
211+
- Description
212+
213+
* - **records**
214+
- The total number of records a MongoDB source task passed to the
215+
{+kafka-connect+} framework.
216+
217+
* - **records-filtered**
218+
- The number of records a MongoDB source task passed to the
219+
{+kafka-connect+} framework that were then filtered by the framework.
220+
A filtered record is not written to Kafka.
221+
222+
* - **records-acknowledged**
223+
- The total number of records a MongoDB source task passed to the
224+
{+kafka-connect+} framework that were then successfully
225+
written to Kafka.
226+
227+
* - **mongodb-bytes-read**
228+
- The total number of bytes a MongoDB source task read from the
229+
MongoDB server.
230+
231+
* - **latest-mongodb-time-difference-secs**
232+
- The number of seconds of the most recent time difference recorded between
233+
a MongoDB server and the post-batch resume token held by a MongoDB
234+
source task. This value is calculated by subtracting the timestamp
235+
of the task's post-batch resume token from the ``operationTime`` value of
236+
the most recent successful MongoDB command executed by the task.
237+
238+
* - **in-task-poll**
239+
- The total number of times the {+kafka-connect+} framework executed
240+
the ``poll()`` method of a MongoDB source task.
241+
242+
* - **in-task-poll-duration-ms**
243+
- The total number of milliseconds the {+kafka-connect+} framework
244+
spent executing the ``poll()`` method of a MongoDB source task.
245+
246+
* - **in-task-poll-duration-over-1-ms**
247+
- The total number of MongoDB source task ``poll()`` method executions
248+
with a duration that exceeded 1 millisecond.
249+
250+
* - **in-task-poll-duration-over-10-ms**
251+
- The total number of MongoDB source task ``poll()`` method executions
252+
with a duration that exceeded 10 milliseconds.
253+
254+
* - **in-task-poll-duration-over-100-ms**
255+
- The total number of MongoDB source task ``poll()`` method executions
256+
with a duration that exceeded 100 milliseconds.
257+
258+
* - **in-task-poll-duration-over-1000-ms**
259+
- The total number of MongoDB source task ``poll()`` method executions
260+
with a duration that exceeded 1000 milliseconds.
261+
262+
* - **in-task-poll-duration-over-10000-ms**
263+
- The total number of MongoDB source task ``poll()`` method executions
264+
with a duration that exceeded 10000 milliseconds.
265+
266+
* - **in-connect-framework**
267+
- The total number of times code in the {+kafka-connect+} framework
268+
executed after the first invocation of the ``poll()`` method of the
269+
MongoDB source task.
270+
271+
* - **in-connect-framework-duration-ms**
272+
- The total number of milliseconds spent executing code in the
273+
{+kafka-connect+} framework since the framework first invoked the
274+
``poll()`` method of the MongoDB source task. This metric does
275+
not count time executing code in the MongoDB sink task towards the total.
276+
277+
* - **in-connect-framework-duration-over-1-ms**
278+
- The total number of times code in the {+kafka-connect+} framework
279+
executed for a duration that exceeded 1 millisecond.
280+
281+
* - **in-connect-framework-duration-over-10-ms**
282+
- The total number of times code in the {+kafka-connect+} framework
283+
executed for a duration that exceeded 10 milliseconds.
284+
285+
* - **in-connect-framework-duration-over-100-ms**
286+
- The total number of times code in the {+kafka-connect+} framework
287+
executed for a duration that exceeded 100 milliseconds.
288+
289+
* - **in-connect-framework-duration-over-1000-ms**
290+
- The total number of times code in the {+kafka-connect+} framework
291+
executed for a duration that exceeded 1000 milliseconds.
292+
293+
* - **in-connect-framework-duration-over-10000-ms**
294+
- The total number of times code in the {+kafka-connect+} framework
295+
executed for a duration that exceeded 10000 milliseconds.
296+
297+
* - **initial-commands-successful**
298+
- The total number of initial commands issued by a MongoDB source
299+
task that succeeded. An initial command is a find or aggregate command
300+
sent to a MongoDB server that retrieves the first set of documents in a
301+
cursor. A ``getMore`` command is not an initial command.
302+
303+
* - **initial-commands-successful-duration-ms**
304+
- The total number of milliseconds a MongoDB source task spent executing
305+
initial commands that succeeded.
306+
307+
* - **initial-commands-successful-duration-over-1-ms**
308+
- The total number of successful initial commands issued by a MongoDB
309+
source task with a duration that exceeded 1 millisecond.
310+
311+
* - **initial-commands-successful-duration-over-10-ms**
312+
- The total number of successful initial commands issued by a MongoDB
313+
source task with a duration that exceeded 10 milliseconds.
314+
315+
* - **initial-commands-successful-duration-over-100-ms**
316+
- The total number of successful initial commands issued by a MongoDB
317+
source task with a duration that exceeded 100 milliseconds.
318+
319+
* - **initial-commands-successful-duration-over-1000-ms**
320+
- The total number of successful initial commands issued by a MongoDB
321+
source task with a duration that exceeded 1000 milliseconds.
322+
323+
* - **initial-commands-successful-duration-over-10000-ms**
324+
- The total number of successful initial commands issued by a MongoDB
325+
source task with a duration that exceeded 10000 milliseconds.
326+
327+
* - **getmore-commands-successful**
328+
- The total number of ``getMore`` commands issued by a MongoDB source
329+
task that succeeded.
330+
331+
* - **getmore-commands-successful-duration-ms**
332+
- The total number of milliseconds a MongoDB source task spent executing
333+
``getMore`` commands that succeeded.
334+
335+
* - **getmore-commands-successful-duration-over-1-ms**
336+
- The total number of successful ``getMore`` commands issued by a
337+
MongoDB source task with a duration that exceeded 1 millisecond.
338+
339+
* - **getmore-commands-successful-duration-over-10-ms**
340+
- The total number of successful ``getMore`` commands issued by a MongoDB
341+
source task with a duration that exceeded 10 milliseconds.
342+
343+
* - **getmore-commands-successful-duration-over-100-ms**
344+
- The total number of successful ``getMore`` commands issued by a MongoDB
345+
source task with a duration that exceeded 100 milliseconds.
346+
347+
* - **getmore-commands-successful-duration-over-1000-ms**
348+
- The total number of successful ``getMore`` commands issued by a
349+
MongoDB source task with a duration that exceeded 1000 milliseconds.
350+
351+
* - **getmore-commands-successful-duration-over-10000-ms**
352+
- The total number of successful ``getMore`` commands issued by a MongoDB
353+
source task with a duration that exceeded 10000 milliseconds.
354+
355+
* - **initial-commands-failed**
356+
- The total number of initial commands issued by a MongoDB source
357+
task that failed. An initial command is a find or aggregate command
358+
sent to a MongoDB server that retrieves the first set of documents in a
359+
cursor. A ``getMore`` command is not an initial command.
360+
361+
* - **initial-commands-failed-duration-ms**
362+
- The total number of milliseconds a MongoDB source task spent
363+
unsuccessfully attempting to issue initial commands to the MongoDB
364+
server.
365+
366+
* - **initial-commands-failed-duration-over-1-ms**
367+
- The total number of failed initial commands issued by a MongoDB
368+
source task with a duration that exceeded 1 millisecond.
369+
370+
* - **initial-commands-failed-duration-over-10-ms**
371+
- The total number of failed initial commands issued by a
372+
MongoDB source task with a duration that exceeded 10 milliseconds.
373+
374+
* - **initial-commands-failed-duration-over-100-ms**
375+
- The total number of failed initial commands issued by a MongoDB source
376+
task with a duration that exceeded 100 milliseconds.
377+
378+
* - **initial-commands-failed-duration-over-1000-ms**
379+
- The total number of failed initial commands issued by a MongoDB source
380+
task with a duration that exceeded 1000 milliseconds.
381+
382+
* - **initial-commands-failed-duration-over-10000-ms**
383+
- The total number of failed initial commands issued by a MongoDB
384+
source task with a duration that exceeded 10000 milliseconds.
385+
386+
* - **getmore-commands-failed**
387+
- The total number of ``getMore`` commands issued by a MongoDB source
388+
task that failed.
389+
390+
* - **getmore-commands-failed-duration-ms**
391+
- The total number of milliseconds a MongoDB source task spent
392+
unsuccessfully attempting to issue ``getMore`` commands to the MongoDB
393+
server.
394+
395+
* - **getmore-commands-failed-duration-over-1-ms**
396+
- The total number of failed ``getMore`` commands issued by a MongoDB source
397+
task with a duration that exceeded 1 millisecond.
398+
399+
* - **getmore-commands-failed-duration-over-10-ms**
400+
- The total number of failed ``getMore`` commands issued by a MongoDB source
401+
task with a duration that exceeded 10 milliseconds.
402+
403+
* - **getmore-commands-failed-duration-over-100-ms**
404+
- The total number of failed ``getMore`` commands issued by a MongoDB source
405+
task with a duration that exceeded 100 milliseconds.
406+
407+
* - **getmore-commands-failed-duration-over-1000-ms**
408+
- The total number of failed ``getMore`` commands issued by a MongoDB source
409+
task with a duration that exceeded 1000 milliseconds.
410+
411+
* - **getmore-commands-failed-duration-over-10000-ms**
412+
- The total number of failed ``getMore`` commands issued by a MongoDB
413+
source task with a duration that exceeded 10000 milliseconds.

0 commit comments

Comments
 (0)