THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
| Code Block |
|---|
{
CorrelationId => int32
GroupId => String
ConsumerId => String
ErrorCode => int16
} |
Configs
Server side configs
This list is still in progress
max.session.timeout - The session timeout for any group should not be higher than this value to reduce overhead on the brokers. If it does, the broker sends a SessionTimeoutTooHigh error code in the JoinGroupResponse
min.heartbeat.interval - The heartbeat interval should not be lower than this value to prevent the consumers from sending too many heartbeats to the server. If the session.timeout.ms/heartbeat.frequency in the JoinGroupRequest falls below this value, the server sends a HeartbeatFrequencyTooHigh error code in the JoinGroupResponseTBD
Wildcard Subscription
With wildcard subscription (for example, whitelist and blacklist), the consumers are responsible to discover matching topics through topic metadata request. That is, its topic metadata request will contain an empty topic list, whose response then will return the partition info of all topics, it will then filter the topics that match its wildcard expression, and then updates the subscription list. Again, if the subscription list has changed from the previous values, it will trigger rebalance for the consumer group.
...