package protocol

Get desktop application:
View/edit binary Protocol Buffers messages

Used in: RaftLog

• string groupId = 1

• string coordinator = 2

Used in: RaftLog

• string stream = 1

• int32 partition = 2

• string leader = 3

Used in: ConsumerGroup

• string id = 1

• repeated string streams = 2

Used in: CreateConsumerGroupOp, MetadataSnapshot

• string id = 1

• repeated Consumer members = 2

• string coordinator = 3

• uint64 epoch = 4

Used in: RaftLog

• optional ConsumerGroup consumerGroup = 1

Used in: PropagatedRequest, RaftLog

• optional Stream stream = 1

• string stream = 1

• int32 partition = 2

• string cursorId = 3

• int64 offset = 4

Used in: PropagatedRequest, RaftLog

• string stream = 1

Used in: PropagatedResponse

• uint32 code = 1

• string msg = 2

Used in: PropagatedRequest, RaftLog

• string stream = 1

• int32 partition = 2

• string replicaToAdd = 3

• string leader = 4

• uint64 leaderEpoch = 5

Used in: PropagatedRequest, RaftLog

• string groupId = 1

• string consumerId = 2

• repeated string streams = 3

• uint64 leaderEpoch = 1

• int64 endOffset = 1

Used in: PropagatedRequest, RaftLog

• string groupId = 1

• string consumerId = 2

• bool expired = 3

  If consumer was removed because they timed out.

• repeated Stream streams = 1

• repeated ConsumerGroup groups = 2

Used in: StreamConfig

• bool value = 1

Used in: StreamConfig

• int32 value = 1

Used in: StreamConfig

• int64 value = 1

Used in: PropagatedRequest, PropagatedResponse, RaftLog

• CREATE_STREAM = 0

• SHRINK_ISR = 1

• REPORT_LEADER = 2

• CHANGE_LEADER = 3

• EXPAND_ISR = 4

• DELETE_STREAM = 5

• PAUSE_STREAM = 6

• RESUME_STREAM = 7

• PUBLISH_ACTIVITY = 8

• SET_STREAM_READONLY = 9

• CREATE_CONSUMER_GROUP = 10

• JOIN_CONSUMER_GROUP = 11

• LEAVE_CONSUMER_GROUP = 12

• REPORT_CONSUMER_GROUP_COORDINATOR = 13

• CHANGE_CONSUMER_GROUP_COORDINATOR = 14

Used in: Stream

• string subject = 1

• string stream = 2

• int32 id = 3

• string group = 4

• int32 replicationFactor = 5

• repeated string replicas = 6

• string leader = 7

• repeated string isr = 8

• uint64 leaderEpoch = 9

• uint64 epoch = 10

• bool paused = 11

  Only used for snapshotting.

• bool readonly = 12

  Only used for snapshotting.

• string stream = 1

• int32 partition = 2

• string stream = 1

• int32 partition = 2

• bool exists = 1

• bool isLeader = 2

Used in: PropagatedRequest, RaftLog

• string stream = 1

• repeated int32 partitions = 2

• bool resumeAll = 3

• Op op = 1

• optional CreateStreamOp createStreamOp = 2

• optional ShrinkISROp shrinkISROp = 3

• optional ReportLeaderOp reportLeaderOp = 4

• optional ExpandISROp expandISROp = 5

• optional DeleteStreamOp deleteStreamOp = 6

• optional PauseStreamOp pauseStreamOp = 7

• optional ResumeStreamOp resumeStreamOp = 8

• optional SetStreamReadonlyOp setStreamReadonlyOp = 9

• optional JoinConsumerGroupOp joinConsumerGroupOp = 10

• optional LeaveConsumerGroupOp leaveConsumerGroupOp = 11

• optional ReportConsumerGroupCoordinatorOp reportConsumerGroupCoordinatorOp = 12

• Op op = 1

• optional Error error = 2

• optional PropagatedResponse.JoinConsumerGroupResponse joinConsumerGroupResp = 11

  Reserving = 12 for leaveConsumerGroupResp if needed. Reserving = 13 for reportConsumerGroupCoordinatorResp if needed.

Reserving = 3 for createStreamResp if needed. Reserving = 4 for shrinkISRResp if needed. Reserving = 5 for reportLeaderResp if needed. Reserving = 6 for expandISRResp if needed. Reserving = 7 for deleteStreamResp if needed. Reserving = 8 for pauseStreamResp if needed. Reserving = 9 for resumeStreamResp if needed. Reserving = 10 for setStreamReadonlyResp if needed.

Used in: PropagatedResponse

• string coordinator = 1

• uint64 epoch = 2

Used in: RaftLog

• uint64 raftIndex = 1

RaftJoinRequest is a request to join a Raft group.

• string nodeID = 1

  ID of the joining node.

• string nodeAddr = 2

  Address of the joining node.

RaftJoinResponse is a response to a RaftJoinRequest.

• string error = 1

  Error string, omitted if no error.

• Op op = 1

• optional CreateStreamOp createStreamOp = 2

• optional ShrinkISROp shrinkISROp = 3

• optional ChangeLeaderOp changeLeaderOp = 4

• optional ExpandISROp expandISROp = 5

• optional DeleteStreamOp deleteStreamOp = 6

• optional PauseStreamOp pauseStreamOp = 7

• optional ResumeStreamOp resumeStreamOp = 8

• optional PublishActivityOp publishActivityOp = 9

• optional SetStreamReadonlyOp setStreamReadonlyOp = 10

• optional CreateConsumerGroupOp createConsumerGroupOp = 11

• optional JoinConsumerGroupOp joinConsumerGroupOp = 12

• optional LeaveConsumerGroupOp leaveConsumerGroupOp = 13

• optional ChangeConsumerGroupCoordinatorOp changeConsumerGroupCoordinatorOp = 14

• string replicaID = 1

• int64 offset = 2

• uint64 leaderEpoch = 3

Used in: PropagatedRequest

• string groupId = 1

• string consumerId = 2

• string coordinator = 3

• uint64 epoch = 4

Used in: PropagatedRequest

• string stream = 1

• int32 partition = 2

• string replica = 3

• string leader = 4

• uint64 leaderEpoch = 5

Used in: PropagatedRequest, RaftLog

• string stream = 1

• repeated int32 partitions = 2

• string id = 1

• string id = 1

• string host = 2

• int32 port = 3

• string serverID = 1

Used in: PropagatedRequest, RaftLog

• string stream = 1

• repeated int32 partitions = 2

• bool readonly = 3

Used in: PropagatedRequest, RaftLog

• string stream = 1

• int32 partition = 2

• string replicaToRemove = 3

• string leader = 4

• uint64 leaderEpoch = 5

Used in: CreateStreamOp, MetadataSnapshot

• string name = 1

• string subject = 2

• repeated Partition partitions = 3

• optional StreamConfig config = 4

• int64 creationTimestamp = 5

Used in: Stream

• optional NullableInt64 retentionMaxBytes = 1

• optional NullableInt64 retentionMaxMessages = 2

• optional NullableInt64 retentionMaxAge = 3

• optional NullableInt64 cleanerInterval = 4

• optional NullableInt64 segmentMaxBytes = 5

• optional NullableInt64 segmentMaxAge = 6

• optional NullableInt32 compactMaxGoroutines = 7

• optional NullableBool compactEnabled = 8

• optional NullableInt64 autoPauseTime = 9

• optional NullableBool autoPauseDisableIfSubscribers = 10

• optional NullableInt32 minIsr = 11

• optional NullableBool optimisticConcurrencyControl = 12

• optional NullableBool encryption = 13