PublicGetPartitionStartOffsetRequest info about partition.

PublicGetPartitionStartOffsetResponse allow to set start offset for read messages for the partition.

PublicReadBatchOption для различных пожеланий к батчу вроде WithMaxMessages(int).

TopicClient is part of rawtopic.Client.

PublicGetPartitionStartOffsetFunc callback function for optional manage read progress store at own side.

TopicSteamReaderConnect connect to grpc stream when connectionCtx closed stream must stop work and return errors for all methods.