package com.github.bsideup.liiklus

Get desktop application:
View/edit binary Protocol Buffers messages

• rpc Publish (PublishRequest, PublishReply)

  LiiklusService.proto:13

  message PublishRequest

  LiiklusService.proto:56

  • string topic = 1

  • bytes key = 2

  • bytes value = 3

  • oneof event

    • LiiklusEvent liiklusEvent = 4

  message PublishReply

  LiiklusService.proto:68

  • uint32 partition = 1

  • uint64 offset = 2

  • string topic = 3

• rpc Subscribe (SubscribeRequest, stream SubscribeReply)

  LiiklusService.proto:17

  message SubscribeRequest

  LiiklusService.proto:77

  • string topic = 1

  • string group = 2

  • uint32 group_version = 4

  • SubscribeRequest.AutoOffsetReset auto_offset_reset = 3

  message SubscribeReply

  LiiklusService.proto:99

  • oneof reply

    • Assignment assignment = 1

• rpc Receive (ReceiveRequest, stream ReceiveReply)

  LiiklusService.proto:20

  message ReceiveRequest

  LiiklusService.proto:116

  • optional Assignment assignment = 1

  • uint64 last_known_offset = 2

  • ReceiveRequest.ContentFormat format = 3

  message ReceiveReply

  LiiklusService.proto:129

  • oneof reply

    • ReceiveReply.Record record = 1

    • ReceiveReply.LiiklusEventRecord liiklus_event_record = 2

• rpc Ack (AckRequest, google.protobuf.Empty)

  LiiklusService.proto:24

  message AckRequest

  LiiklusService.proto:105

  • optional Assignment assignment = 1

  • string topic = 3

  • string group = 4

  • uint32 group_version = 5

  • uint32 partition = 6

  • uint64 offset = 2

• rpc GetOffsets (GetOffsetsRequest, GetOffsetsReply)

  LiiklusService.proto:28

  message GetOffsetsRequest

  LiiklusService.proto:161

  • string topic = 1

  • string group = 2

  • uint32 group_version = 3

  message GetOffsetsReply

  LiiklusService.proto:171

  • map<uint32, uint64> offsets = 1

• rpc GetEndOffsets (GetEndOffsetsRequest, GetEndOffsetsReply)

  LiiklusService.proto:32

  message GetEndOffsetsRequest

  LiiklusService.proto:175

  • string topic = 1

  message GetEndOffsetsReply

  LiiklusService.proto:179

  • map<uint32, uint64> offsets = 1

Used in: AckRequest, ReceiveRequest, SubscribeReply

• string session_id = 1

• uint32 partition = 2

Used in: PublishRequest, ReceiveReply.LiiklusEventRecord

• string id = 1

  Required

• string type = 2

  Required

• string source = 3

  Required

• string time = 5

• string data_content_type = 100

• bytes data = 101

• map<string, string> extensions = 200

Used in: ReceiveReply

• uint64 offset = 1

• bytes key = 2

• optional LiiklusEvent event = 3

• optional google.protobuf.Timestamp timestamp = 4

  TODO drop?

• bool replay = 5

Used in: ReceiveReply

• uint64 offset = 1

• bytes key = 2

• bytes value = 3

• optional google.protobuf.Timestamp timestamp = 4

• bool replay = 5

Used in: ReceiveRequest

• BINARY = 0

• LIIKLUS_EVENT = 1

Used in: SubscribeRequest

• EARLIEST = 0

• LATEST = 1