static io.netty.buffer.ByteBuf |
Commands.newGetSchemaResponse(long requestId,
SchemaInfo schema,
SchemaVersion version) |
static io.netty.buffer.ByteBuf |
Commands.newProducer(String topic,
long producerId,
long requestId,
String producerName,
boolean encrypted,
Map<String,String> metadata,
SchemaInfo schemaInfo) |
static io.netty.buffer.ByteBuf |
Commands.newSubscribe(String topic,
String subscription,
long consumerId,
long requestId,
PulsarApi.CommandSubscribe.SubType subType,
int priorityLevel,
String consumerName,
boolean isDurable,
PulsarApi.MessageIdData startMessageId,
Map<String,String> metadata,
boolean readCompacted,
PulsarApi.CommandSubscribe.InitialPosition subscriptionInitialPosition,
SchemaInfo schemaInfo) |