syntax = "proto3"; import "google/protobuf/timestamp.proto"; package nodata; service NoData { rpc PublishEvent(PublishEventRequest) returns (PublishEventResponse) {} } message PublishEventRequest { string topic = 1; google.protobuf.Timestamp published = 2; string key = 3; bytes value = 4; } message PublishEventResponse { }