-
Notifications
You must be signed in to change notification settings - Fork 297
Closed
Labels
enhancementA change that improves our (or users) QoLA change that improves our (or users) QoLjavaIssues related to Java SDKIssues related to Java SDK
Description
Title: [Java SDK] Implement automatic consumer group rebalancing
Description:
Current SDK requires manual consumer group management without automatic rebalancing.
Proposed Solution:
// Automatic rebalancing
ConsumerGroup group = client.joinConsumerGroup(
"my-group",
ConsumerGroupConfig.builder()
.rebalanceStrategy(RebalanceStrategy.RANGE)
.sessionTimeout(Duration.ofSeconds(30))
.heartbeatInterval(Duration.ofSeconds(3))
.onPartitionsAssigned(partitions -> {...})
.onPartitionsRevoked(partitions -> {...})
.build()
);Reactions are currently unavailable
Metadata
Metadata
Assignees
Labels
enhancementA change that improves our (or users) QoLA change that improves our (or users) QoLjavaIssues related to Java SDKIssues related to Java SDK