[ https://issues.apache.org/jira/browse/KAFKA-16950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Andrew Schofield resolved KAFKA-16950. -------------------------------------- Resolution: Fixed > Define Persister and Share Coordinator RPCs > ------------------------------------------- > > Key: KAFKA-16950 > URL: https://issues.apache.org/jira/browse/KAFKA-16950 > Project: Kafka > Issue Type: Sub-task > Reporter: Apoorv Mittal > Assignee: Andrew Schofield > Priority: Major > > 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. > > > {code:java} > 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; {code} > > -- This message was sent by Atlassian Jira (v8.20.10#820010)