Enhanced Streams Service Schema

syntax = "proto3";package nln.stream.v1; service StreamService {  rpc Subscribe(SubscribeRequest) returns (stream SubscribeResponse);  rpc ListTopics(ListTopicsRequest) returns (ListTopicsResponse);} message SubscribeRequest {  string topic = 1;  OutputFormat format = 2;} enum OutputFormat {  PROTO = 0;  JSON = 1;} message SubscribeResponse {  string topic = 1;  int64 partition = 2;  int64 offset = 3;  int64 timestamp_ms = 4;  bytes payload = 5;} message ListTopicsRequest {} message ListTopicsResponse {  repeated TopicInfo topics = 1;} message TopicInfo {  string name = 1;  string description = 2;  string proto_message_type = 3;}

npm install @grpc/grpc-js @grpc/proto-loader

import grpc from "@grpc/grpc-js"import protoLoader from "@grpc/proto-loader" const definition = protoLoader.loadSync("enhanced-streams.proto", {  keepCase: false,  longs: String,  enums: String,  defaults: true,  oneofs: true,}) const nln = grpc.loadPackageDefinition(definition).nln.stream.v1