THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
We will support two assignors out of the box for Apache Kafka:
- range - org.apache.kafka.server.group.consumer.RangeAssignor - An assignor which co-partitions topics.
- uniform - org.apache.kafka.server.group.consumer.UniformAssignor - An assignor which uniformly assign partitions amongst the members. This is somewhat similar to the existing "sticky" assignor.
...
| 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" }
],
} |
...
OffsetCommitValue
| Code Block | ||||
|---|---|---|---|---|
| ||||
{
"type": "data",
"name": "OffsetCommitValue",
"validVersions": "0-4",
"flexibleVersions": "4+",
"fields": [
{ "name": "offset", "type": "int64", "versions": "0+" },
{ "name": "leaderEpoch", "type": "int32", "versions": "3+", "default": -1, "ignorable": true },
{ "name": "metadata", "type": "string", "versions": "0+" },
{ "name": "commitTimestamp", "type": "int64", "versions": "0+" },
{ "name": "expireTimestamp", "type": "int64", "versions": "1", "default": -1, "ignorable": true },
// Adds TopicId field.
{ "name": "topicId", "type": "uuid", "versions": "4", "ignorable": true }
]
} |
...
| Name | Type | Default | Doc |
|---|---|---|---|
| group.coordinator.threads | int | 1 | The number of threads used to run the state machines. |
| group.consumer.session.timeout.ms | int | 45s | 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 | listrange, uniform | org.apache.kafka.server.group.consumer.RangeAssignor, org.apache.kafka.server.group.consumer.UniformAssignor | The server side assignors as a list of full class names. The first one in the list is considered as the default assignor to be used in the case where the consumer does not specify an assignor. |
...