Serialized Form

Package io.confluent.kafka.odyssey

Exception Class io.confluent.kafka.odyssey.LsrcLookupException

class LsrcLookupException extends RuntimeException implements Serializable

Exception Class io.confluent.kafka.odyssey.LsrcLookupException.InvalidLkcIdException

class InvalidLkcIdException extends LsrcLookupException implements Serializable

Exception Class io.confluent.kafka.odyssey.LsrcLookupException.LsrcLookupServiceException

class LsrcLookupServiceException extends LsrcLookupException implements Serializable

Exception Class io.confluent.kafka.odyssey.LsrcLookupException.LsrcMappingNotFoundException

class LsrcMappingNotFoundException extends LsrcLookupException implements Serializable

Package io.confluent.kafka.odyssey.auth

Exception Class io.confluent.kafka.odyssey.auth.TokenPlatformException

class TokenPlatformException extends Exception implements Serializable

Serialized Fields

errorType

TokenPlatformException.ErrorType errorType

grpcStatusCode

String grpcStatusCode

Package io.confluent.rm.clusterlink.v1

Class io.confluent.rm.clusterlink.v1.GlobalLogicalKafkaCluster

class GlobalLogicalKafkaCluster extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

bitField0_

int bitField0_

memoizedIsInitialized

byte memoizedIsInitialized

metadata_

io.confluent.resourcemanager.protobuf.apis.meta.v1.ObjectMeta metadata_

spec_

io.confluent.rm.clusterlink.v1.GlobalLogicalKafkaClusterSpec spec_

Class io.confluent.rm.clusterlink.v1.GlobalLogicalKafkaClusterList

class GlobalLogicalKafkaClusterList extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

bitField0_

int bitField0_

items_

List<io.confluent.rm.clusterlink.v1.GlobalLogicalKafkaCluster> items_

memoizedIsInitialized

byte memoizedIsInitialized

metadata_

io.confluent.resourcemanager.protobuf.apis.meta.v1.ListMeta metadata_

Class io.confluent.rm.clusterlink.v1.GlobalLogicalKafkaClusterSpec

class GlobalLogicalKafkaClusterSpec extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

bitField0_

int bitField0_

cloud_

Object cloud_

displayName_

Object displayName_

internalUrl_

Object internalUrl_

memoizedIsInitialized

byte memoizedIsInitialized

networkId_

Object networkId_

physicalClusterId_

Object physicalClusterId_

region_

Object region_

sku_

Object sku_

Class io.confluent.rm.clusterlink.v1.GlobalSite

class GlobalSite extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

bitField0_

int bitField0_

memoizedIsInitialized

byte memoizedIsInitialized

metadata_

io.confluent.resourcemanager.protobuf.apis.meta.v1.ObjectMeta metadata_

spec_

io.confluent.rm.clusterlink.v1.GlobalSiteSpec spec_

Class io.confluent.rm.clusterlink.v1.GlobalSiteList

class GlobalSiteList extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

bitField0_

int bitField0_

items_

List<io.confluent.rm.clusterlink.v1.GlobalSite> items_

memoizedIsInitialized

byte memoizedIsInitialized

metadata_

io.confluent.resourcemanager.protobuf.apis.meta.v1.ListMeta metadata_

Class io.confluent.rm.clusterlink.v1.GlobalSiteSpec

class GlobalSiteSpec extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

bitField0_

int bitField0_

connectionTypes_

com.google.protobuf.LazyStringArrayList connectionTypes_

displayName_

Object displayName_

memoizedIsInitialized

byte memoizedIsInitialized

needsIngressEdge_

boolean needsIngressEdge_

Package io.confluent.rm.kafka.v1

Class io.confluent.rm.kafka.v1.DeletedTopic

class DeletedTopic extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

bitField0_

int bitField0_

deletedTopicSpec_

io.confluent.rm.kafka.v1.DeletedTopicSpec deletedTopicSpec_

memoizedIsInitialized

byte memoizedIsInitialized

metadata_

io.confluent.resourcemanager.protobuf.apis.meta.v1.ObjectMeta metadata_

Class io.confluent.rm.kafka.v1.DeletedTopicSpec

class DeletedTopicSpec extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

bitField0_

int bitField0_

memoizedIsInitialized

byte memoizedIsInitialized

topicName_

Object topicName_

topicSpec_

io.confluent.rm.kafka.v1.TopicSpec topicSpec_

Class io.confluent.rm.kafka.v1.DynamicConfigs

class DynamicConfigs extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

dynamicConfigs_

com.google.protobuf.MapField<String,String> dynamicConfigs_

memoizedIsInitialized

byte memoizedIsInitialized

Class io.confluent.rm.kafka.v1.GlobalStore

class GlobalStore extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

bitField0_

int bitField0_

memoizedIsInitialized

byte memoizedIsInitialized

processor_

io.confluent.rm.kafka.v1.TopologyNode processor_

source_

io.confluent.rm.kafka.v1.TopologyNode source_

Class io.confluent.rm.kafka.v1.GroupConfig

class GroupConfig extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

bitField0_

int bitField0_

memoizedIsInitialized

byte memoizedIsInitialized

metadata_

io.confluent.resourcemanager.protobuf.apis.meta.v1.ObjectMeta metadata_

spec_

io.confluent.rm.kafka.v1.GroupConfigSpec spec_

Class io.confluent.rm.kafka.v1.GroupConfigList

class GroupConfigList extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

bitField0_

int bitField0_

items_

List<io.confluent.rm.kafka.v1.GroupConfig> items_

memoizedIsInitialized

byte memoizedIsInitialized

metadata_

io.confluent.resourcemanager.protobuf.apis.meta.v1.ListMeta metadata_

Class io.confluent.rm.kafka.v1.GroupConfigSpec

class GroupConfigSpec extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

bitField0_

int bitField0_

groupConfigs_

io.confluent.rm.kafka.v1.GroupDynamicConfigs groupConfigs_

memoizedIsInitialized

byte memoizedIsInitialized

Class io.confluent.rm.kafka.v1.GroupDynamicConfigs

class GroupDynamicConfigs extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

dynamicConfigs_

com.google.protobuf.MapField<String,String> dynamicConfigs_

memoizedIsInitialized

byte memoizedIsInitialized

Class io.confluent.rm.kafka.v1.HealthProbe

class HealthProbe extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

bitField0_

int bitField0_

memoizedIsInitialized

byte memoizedIsInitialized

metadata_

io.confluent.resourcemanager.protobuf.apis.meta.v1.ObjectMeta metadata_

spec_

io.confluent.rm.kafka.v1.HealthProbeSpec spec_

Class io.confluent.rm.kafka.v1.HealthProbeList

class HealthProbeList extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

bitField0_

int bitField0_

items_

List<io.confluent.rm.kafka.v1.HealthProbe> items_

memoizedIsInitialized

byte memoizedIsInitialized

metadata_

io.confluent.resourcemanager.protobuf.apis.meta.v1.ListMeta metadata_

Class io.confluent.rm.kafka.v1.HealthProbeSpec

class HealthProbeSpec extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

memoizedIsInitialized

byte memoizedIsInitialized

probeCount_

long probeCount_

Class io.confluent.rm.kafka.v1.LogicalKafkaCluster

class LogicalKafkaCluster extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

bitField0_

int bitField0_

memoizedIsInitialized

byte memoizedIsInitialized

metadata_

io.confluent.resourcemanager.protobuf.apis.meta.v1.ObjectMeta metadata_

spec_

io.confluent.rm.kafka.v1.LogicalKafkaClusterSpec spec_

status_

io.confluent.rm.kafka.v1.LogicalKafkaClusterStatus status_

Class io.confluent.rm.kafka.v1.LogicalKafkaClusterList

class LogicalKafkaClusterList extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

bitField0_

int bitField0_

items_

List<io.confluent.rm.kafka.v1.LogicalKafkaCluster> items_

memoizedIsInitialized

byte memoizedIsInitialized

metadata_

io.confluent.resourcemanager.protobuf.apis.meta.v1.ListMeta metadata_

Class io.confluent.rm.kafka.v1.LogicalKafkaClusterSpec

class LogicalKafkaClusterSpec extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

bitField0_

int bitField0_

memoizedIsInitialized

byte memoizedIsInitialized

placement_

io.confluent.rm.kafka.v1.Placement placement_

Class io.confluent.rm.kafka.v1.LogicalKafkaClusterStatus

class LogicalKafkaClusterStatus extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

memoizedIsInitialized

byte memoizedIsInitialized

Class io.confluent.rm.kafka.v1.MirrorTopicSpec

class MirrorTopicSpec extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

bitField0_

int bitField0_

clusterLinkId_

io.confluent.rm.kafka.v1.Uuid clusterLinkId_

clusterLinkName_

Object clusterLinkName_

memoizedIsInitialized

byte memoizedIsInitialized

mirrorTopicState_

Object mirrorTopicState_

sourceTopicId_

io.confluent.rm.kafka.v1.TopicId sourceTopicId_

sourceTopicName_

Object sourceTopicName_

Class io.confluent.rm.kafka.v1.MirrorTopicStatus

class MirrorTopicStatus extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

bitField0_

int bitField0_

lastSwitchoverMetadata_

io.confluent.rm.kafka.v1.MirrorTopicSwitchoverMetadata lastSwitchoverMetadata_

linkLevelPause_

boolean linkLevelPause_

memoizedIsInitialized

byte memoizedIsInitialized

mirrorStartOffsets_

com.google.protobuf.Internal.LongList mirrorStartOffsets_

mirrorStartOffsetsMemoizedSerializedSize

int mirrorStartOffsetsMemoizedSerializedSize

mirrorTopicError_

int mirrorTopicError_

nextState_

Object nextState_

previousToPausedState_

Object previousToPausedState_

promoted_

boolean promoted_

stoppedEpochs_

com.google.protobuf.Internal.IntList stoppedEpochs_

stoppedEpochsMemoizedSerializedSize

int stoppedEpochsMemoizedSerializedSize

stoppedLogEndOffsets_

com.google.protobuf.Internal.LongList stoppedLogEndOffsets_

stoppedLogEndOffsetsMemoizedSerializedSize

int stoppedLogEndOffsetsMemoizedSerializedSize

stoppedSequenceNumber_

long stoppedSequenceNumber_

timeMs_

long timeMs_

topicLevelPause_

boolean topicLevelPause_

truncationEpochs_

com.google.protobuf.Internal.IntList truncationEpochs_

truncationEpochsMemoizedSerializedSize

int truncationEpochsMemoizedSerializedSize

truncationOffsets_

com.google.protobuf.Internal.LongList truncationOffsets_

truncationOffsetsMemoizedSerializedSize

int truncationOffsetsMemoizedSerializedSize

Class io.confluent.rm.kafka.v1.MirrorTopicSwitchoverMetadata

class MirrorTopicSwitchoverMetadata extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

errorCode_

int errorCode_

errorMessage_

Object errorMessage_

memoizedIsInitialized

byte memoizedIsInitialized

messagesTruncated_

long messagesTruncated_

Class io.confluent.rm.kafka.v1.Partitions

class Partitions extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

memoizedIsInitialized

byte memoizedIsInitialized

partitions_

int partitions_

Class io.confluent.rm.kafka.v1.Placement

class Placement extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

cloud_

int cloud_

memoizedIsInitialized

byte memoizedIsInitialized

networkId_

Object networkId_

physicalClusterId_

Object physicalClusterId_

region_

Object region_

Class io.confluent.rm.kafka.v1.StreamsTopology

class StreamsTopology extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

bitField0_

int bitField0_

memoizedIsInitialized

byte memoizedIsInitialized

metadata_

io.confluent.resourcemanager.protobuf.apis.meta.v1.ObjectMeta metadata_

spec_

io.confluent.rm.kafka.v1.StreamsTopologySpec spec_

Class io.confluent.rm.kafka.v1.StreamsTopologyList

class StreamsTopologyList extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

bitField0_

int bitField0_

items_

List<io.confluent.rm.kafka.v1.StreamsTopology> items_

memoizedIsInitialized

byte memoizedIsInitialized

metadata_

io.confluent.resourcemanager.protobuf.apis.meta.v1.ListMeta metadata_

Class io.confluent.rm.kafka.v1.StreamsTopologySpec

class StreamsTopologySpec extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

epoch_

int epoch_

globalStores_

List<io.confluent.rm.kafka.v1.GlobalStore> globalStores_

groupId_

Object groupId_

memoizedIsInitialized

byte memoizedIsInitialized

publishStatus_

int publishStatus_

rejectionDetail_

Object rejectionDetail_

subtopologies_

List<io.confluent.rm.kafka.v1.Subtopology> subtopologies_

Class io.confluent.rm.kafka.v1.Subtopology

class Subtopology extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

id_

Object id_

memoizedIsInitialized

byte memoizedIsInitialized

nodes_

List<io.confluent.rm.kafka.v1.TopologyNode> nodes_

Class io.confluent.rm.kafka.v1.Table

class Table extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

memoizedIsInitialized

byte memoizedIsInitialized

options_

com.google.protobuf.MapField<String,String> options_

Class io.confluent.rm.kafka.v1.Topic

class Topic extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

bitField0_

int bitField0_

memoizedIsInitialized

byte memoizedIsInitialized

metadata_

io.confluent.resourcemanager.protobuf.apis.meta.v1.ObjectMeta metadata_

spec_

io.confluent.rm.kafka.v1.TopicSpec spec_

status_

io.confluent.rm.kafka.v1.TopicStatus status_

Class io.confluent.rm.kafka.v1.TopicId

class TopicId extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

lsb_

long lsb_

memoizedIsInitialized

byte memoizedIsInitialized

msb_

long msb_

Class io.confluent.rm.kafka.v1.TopicList

class TopicList extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

bitField0_

int bitField0_

items_

List<io.confluent.rm.kafka.v1.Topic> items_

memoizedIsInitialized

byte memoizedIsInitialized

metadata_

io.confluent.resourcemanager.protobuf.apis.meta.v1.ListMeta metadata_

Class io.confluent.rm.kafka.v1.TopicSpec

class TopicSpec extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

bitField0_

int bitField0_

description_

Object description_

dynamicConfigs_

io.confluent.rm.kafka.v1.DynamicConfigs dynamicConfigs_

kindData_

Object kindData_

kindDataCase_

int kindDataCase_

memoizedIsInitialized

byte memoizedIsInitialized

mirrorTopicSpec_

io.confluent.rm.kafka.v1.MirrorTopicSpec mirrorTopicSpec_

partitions_

io.confluent.rm.kafka.v1.Partitions partitions_

tableKind_

int tableKind_

topicId_

io.confluent.rm.kafka.v1.TopicId topicId_

Class io.confluent.rm.kafka.v1.TopicStatus

class TopicStatus extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

bitField0_

int bitField0_

memoizedIsInitialized

byte memoizedIsInitialized

mirrorTopicStatus_

io.confluent.rm.kafka.v1.MirrorTopicStatus mirrorTopicStatus_

partitionLeaderEpochs_

com.google.protobuf.Internal.IntList partitionLeaderEpochs_

partitionLeaderEpochsMemoizedSerializedSize

int partitionLeaderEpochsMemoizedSerializedSize

partitionUpdaterTokens_

com.google.protobuf.Internal.LongList partitionUpdaterTokens_

partitionUpdaterTokensMemoizedSerializedSize

int partitionUpdaterTokensMemoizedSerializedSize

partitionWriterTokens_

com.google.protobuf.Internal.LongList partitionWriterTokens_

partitionWriterTokensMemoizedSerializedSize

int partitionWriterTokensMemoizedSerializedSize

Class io.confluent.rm.kafka.v1.TopologyNode

class TopologyNode extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

memoizedIsInitialized

byte memoizedIsInitialized

name_

Object name_

stores_

com.google.protobuf.LazyStringArrayList stores_

successors_

com.google.protobuf.LazyStringArrayList successors_

topic_

Object topic_

topics_

com.google.protobuf.LazyStringArrayList topics_

type_

int type_

Class io.confluent.rm.kafka.v1.Uuid

class Uuid extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

lsb_

long lsb_

memoizedIsInitialized

byte memoizedIsInitialized

msb_

long msb_

Class io.confluent.rm.kafka.v1.View

class View extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

expandedQuery_

Object expandedQuery_

memoizedIsInitialized

byte memoizedIsInitialized

query_

Object query_