cckellogg commented on a change in pull request #560:
URL: https://github.com/apache/pulsar-client-go/pull/560#discussion_r697165157
##
File path: pulsar/internal/key_based_batch_builder.go
##
@@ -203,21 +205,23 @@ func (bc *keyBasedBatchContainer) FlushBatches() (
sort
cckellogg commented on a change in pull request #560:
URL: https://github.com/apache/pulsar-client-go/pull/560#discussion_r696781044
##
File path: pulsar/internal/commands.go
##
@@ -221,9 +222,21 @@ func serializeBatch(wb Buffer,
cmdSend *pb.BaseCommand,
msgMeta
cckellogg commented on a change in pull request #560:
URL: https://github.com/apache/pulsar-client-go/pull/560#discussion_r694126951
##
File path: pulsar/internal/commands.go
##
@@ -221,9 +222,21 @@ func serializeBatch(wb Buffer,
cmdSend *pb.BaseCommand,
msgMeta
cckellogg commented on a change in pull request #560:
URL: https://github.com/apache/pulsar-client-go/pull/560#discussion_r685401565
##
File path: pulsar/internal/crypto/producer_encryptor.go
##
@@ -0,0 +1,72 @@
+// Licensed to the Apache Software Foundation (ASF) under one
+//
cckellogg commented on a change in pull request #560:
URL: https://github.com/apache/pulsar-client-go/pull/560#discussion_r680642756
##
File path: pulsar/producer_partition.go
##
@@ -126,6 +129,23 @@ func newPartitionProducer(client *client, topic string,
options *ProducerOpti
cckellogg commented on a change in pull request #560:
URL: https://github.com/apache/pulsar-client-go/pull/560#discussion_r667584019
##
File path: pulsar/internal/commands.go
##
@@ -269,6 +270,117 @@ func serializeBatch(wb Buffer,
wb.PutUint32(checksum, checksumIdx)
}
