|
6 | 6 | "type": "object", |
7 | 7 | "properties": { |
8 | 8 | "group_session_timeout": { |
9 | | - "description": "timeout used to detect consumer failures when using Kafka's group management facility. The consumer sends periodic heartbeats to indicate its liveness to the broker. If no heartbeats are received by the broker before the expiration of this session timeout, then the broker will remove this consumer from the group and initiate a rebalance. Note that the value must be in the allowable range as configured in the broker configuration by `group.min.session.timeout.ms` and `group.max.session.timeout.ms`", |
| 9 | + "description": "Timeout used to detect consumer failures when using Kafka's group management facility. The consumer sends periodic heartbeats to indicate its liveness to the broker. If no heartbeats are received by the broker before the expiration of this session timeout, then the broker will remove this consumer from the group and initiate a rebalance. Note that the value must be in the allowable range as configured in the broker configuration by `group.min.session.timeout.ms` and `group.max.session.timeout.ms`", |
10 | 10 | "default": "10s", |
11 | 11 | "$ref": "../../timeunits.json#/$defs/timeunit", |
12 | 12 | "type": "string" |
13 | 13 | }, |
14 | 14 | "group_heartbeat_interval": { |
15 | 15 | "title": "Grup Heartbeat Interval", |
16 | | - "description": "the expected time between heartbeats to the consumer coordinator when using Kafka's group management facilities. Heartbeats are used to ensure that the consumer's session stays active and to facilitate rebalancing when new consumers join or leave the group. The value must be set lower than Consumer.Group.Session.Timeout, but typically should be set no higher than 1/3 of that value. It can be adjusted even lower to control the expected time for normal rebalances", |
| 16 | + "description": "Expected time between heartbeats to the consumer coordinator when using Kafka's group management facilities. Heartbeats are used to ensure that the consumer's session stays active and to facilitate rebalancing when new consumers join or leave the group. The value must be set lower than Consumer.Group.Session.Timeout, but typically should be set no higher than 1/3 of that value. It can be adjusted even lower to control the expected time for normal rebalances", |
17 | 17 | "default": "3s", |
18 | 18 | "$ref": "../../timeunits.json#/$defs/timeunit", |
19 | 19 | "type": "string" |
20 | 20 | }, |
21 | 21 | "group_rebalance_strategies": { |
22 | 22 | "title": "Group Rebalance Strategies", |
23 | | - "description": "the priority-ordered list of client-side consumer group balancing strategies that will be offered to the coordinator. The first strategy that all group members support will be chosen by the leader. Options are: `range`, `roundrobin`, and `sticky`", |
| 23 | + "description": "Priority-ordered list of client-side consumer group balancing strategies that will be offered to the coordinator. The first strategy that all group members support will be chosen by the leader. Options are: `range`, `roundrobin`, and `sticky`", |
24 | 24 | "default": [ "range" ], |
25 | 25 | "type": "array", |
26 | 26 | "items": { |
|
29 | 29 | }, |
30 | 30 | "group_rebalance_timeout": { |
31 | 31 | "title": "Group Rebalance Timeout", |
32 | | - "description": "the maximum allowed time for each worker to join the group once a rebalance has begun. This is basically a limit on the amount of time needed for all tasks to flush any pending data and commit offsets. If the timeout is exceeded, then the worker will be removed from the group, which will cause offset commit failures.", |
| 32 | + "description": "Maximum allowed time for each worker to join the group once a rebalance has begun. This is basically a limit on the amount of time needed for all tasks to flush any pending data and commit offsets. If the timeout is exceeded, then the worker will be removed from the group, which will cause offset commit failures.", |
33 | 33 | "default": "60s", |
34 | 34 | "$ref": "../../timeunits.json#/$defs/timeunit", |
35 | 35 | "type": "string" |
36 | 36 | }, |
37 | 37 | "group_instance_id": { |
38 | 38 | "title": "Group Instance ID", |
39 | | - "description": "support KIP-345", |
| 39 | + "description": "Support KIP-345", |
40 | 40 | "type": "string" |
41 | 41 | }, |
42 | 42 | "fetch_default": { |
|
46 | 46 | }, |
47 | 47 | "isolation_level": { |
48 | 48 | "title": "Isolation Level", |
49 | | - "description": "supports 2 modes: `read_commited` to consume and return all messages in message channel, and `read_uncommited` to hide messages that are part of an aborted transaction", |
| 49 | + "description": "Supports 2 modes: `read_commited` to consume and return all messages in message channel, and `read_uncommited` to hide messages that are part of an aborted transaction", |
50 | 50 | "type": "string", |
51 | 51 | "default": "read_commited", |
52 | 52 | "enum": [ "read_commited", "read_uncommited" ] |
|
0 commit comments