[KAFKA-16950] Define Persister and Share Coordinator RPCs

• Type: Sub-task
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Assignee: Andrew Schofield
• Reporter: Apoorv Mittal
• Created: 13/Jun/24 16:41
• Updated: 15/Jun/24 18:56
• Resolved: 15/Jun/24 18:56

Description

Add Persister interface with schemas for RPCs. The classes which are needed by SharePartition to integrate are below, note some of them results from the generated json schema classes.

 

 

import org.apache.kafka.server.group.share.GroupTopicPartitionData;
import org.apache.kafka.server.group.share.PartitionAllData;
import org.apache.kafka.server.group.share.PartitionErrorData;
import org.apache.kafka.server.group.share.PartitionFactory;
import org.apache.kafka.server.group.share.PartitionIdLeaderEpochData;
import org.apache.kafka.server.group.share.PartitionStateBatchData;
import org.apache.kafka.server.group.share.Persister;
import org.apache.kafka.server.group.share.PersisterStateBatch;
import org.apache.kafka.server.group.share.ReadShareGroupStateParameters;
import org.apache.kafka.server.group.share.ReadShareGroupStateResult;
import org.apache.kafka.server.group.share.TopicData;
import org.apache.kafka.server.group.share.WriteShareGroupStateParameters;
import org.apache.kafka.server.group.share.WriteShareGroupStateResult; 

 

 

Issue Links

• links to: GitHub Pull Request #16335