THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
| Code Block | ||||
|---|---|---|---|---|
| ||||
{
"type": "data",
"name": "ConsumerGroupCurrentMemberAssignmentValue",
"validVersions": "0",
"flexibleVersions": "0+",
"fields": [
{ "name": "MemberEpoch", "versions": "0+", "type": "int32" },
{ "name": "Error", "versions": "0+", "type": "int8" },
{ "name": "TopicPartitions", "versions": "0+",
"type": "[]TopicPartition", "fields": [
{ "name": "TopicId", "versions": "0+", "type": "uuid" },
{ "name": "Partitions", "versions": "0+", "type": "[]int32" }
]},
{ "name": "Version", "versions": "0+", "type": "int16" },
{ "name": "Metadata", "versions": "0+", "type": "bytes" }
],
} |
Group Configurations
GroupConfigurationKey
| Code Block | ||||
|---|---|---|---|---|
| ||||
{
"type": "data",
"name": "GroupConfigurationKey",
"validVersions": "8",
"flexibleVersions": "none",
"fields": [
{ "name": "GroupId", "type": "string", "versions": "8" }
]
} |
...
| Name | Type | Default | Doc |
|---|---|---|---|
| group.new.coordinator.enable | bool | false | Wether to enable the new group coordinator and the consumer group protocol. |
| group.coordinator.threads | int | 1 | The number of threads used to run the state machines. |
| group.consumer.session.timeout.ms | int | 30s | The timeout to detect client failures when using the consumer group protocol. |
| group.consumer.min.session.timeout.ms | int | 45s | The minimum session timeout. |
| group.consumer.max.session.timeout.ms | int | 60s | The maximum session timeout. |
| group.consumer.heartbeat.interval.ms | int | 5s | The heartbeat interval given to the members. |
| group.consumer.min.heartbeat.interval.ms | int | 5s | The minimum heartbeat interval. |
| group.consumer.max.heartbeat.interval.ms | int | 15s | The maximum heartbeat interval. |
| group.consumer.max.size | int | MaxValue | The maximum number of consumers that a single consumer group can accommodate. |
| group.consumer.assignors | List | range, uniform | The server side assignors. |
Group Configurations
New dynamic group properties.
...