You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Copy file name to clipboardExpand all lines: modules/components/pages/inputs/ockam_kafka.adoc
+14-13Lines changed: 14 additions & 13 deletions
Display the source diff
Display the rich diff
Original file line number
Diff line number
Diff line change
@@ -39,6 +39,7 @@ input:
39
39
allow_producer: self
40
40
relay: "" # No default (optional)
41
41
node_address: 127.0.0.1:6262
42
+
encrypted_fields: []
42
43
```
43
44
--
44
45
Advanced::
@@ -80,15 +81,15 @@ input:
80
81
period: "" # No default (optional)
81
82
check: "" # No default (optional)
82
83
processors: [] # No default (optional)
83
-
disable_content_encryption: false
84
-
enrollment_ticket: "" # No default (optional)
85
-
identity_name: "" # No default (optional)
86
-
allow: self
87
-
route_to_kafka_outlet: self
88
-
allow_producer: self
89
-
relay: "" # No default (optional)
90
-
node_address: 127.0.0.1:6262
91
-
encrypted_fields: []
84
+
disable_content_encryption: false
85
+
enrollment_ticket: "" # No default (optional)
86
+
identity_name: "" # No default (optional)
87
+
allow: self
88
+
route_to_kafka_outlet: self
89
+
allow_producer: self
90
+
relay: "" # No default (optional)
91
+
node_address: 127.0.0.1:6262
92
+
encrypted_fields: []
92
93
```
93
94
--
94
95
======
@@ -361,7 +362,7 @@ Whether to consume from the oldest available offset. Otherwise, messages are con
361
362
362
363
*Default*: `true`
363
364
364
-
=== `fetch_max_bytes`
365
+
=== `kafka.fetch_max_bytes`
365
366
366
367
The maximum size of a message batch (in bytes) that a broker tries to send during a client fetch. If individual records exceed the `fetch_max_bytes` value, brokers will still send them.
367
368
@@ -370,23 +371,23 @@ The maximum size of a message batch (in bytes) that a broker tries to send durin
370
371
371
372
*Default*: `50MiB`
372
373
373
-
=== `fetch_max_wait`
374
+
=== `kafka.fetch_max_wait`
374
375
375
376
The maximum period of time a broker can wait for a fetch response to reach the required minimum number of bytes (`fetch_min_bytes`).
376
377
377
378
*Type*: `string`
378
379
379
380
*Default*: `5s`
380
381
381
-
=== `fetch_min_bytes`
382
+
=== `kafka.fetch_min_bytes`
382
383
383
384
The minimum number of bytes that a broker tries to send during a fetch. This field is equivalent to the Java setting `fetch.min.bytes`.
384
385
385
386
*Type*: `string`
386
387
387
388
*Default*: `1B`
388
389
389
-
=== `fetch_max_partition_bytes`
390
+
=== `kafka.fetch_max_partition_bytes`
390
391
391
392
The maximum number of bytes that are consumed from a single partition in a fetch request. This field is equivalent to the Java setting `fetch.max.partition.bytes`.
0 commit comments