diff options
Diffstat (limited to 'weed/mq/segment/message_serde.go')
| -rw-r--r-- | weed/mq/segment/message_serde.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/weed/mq/segment/message_serde.go b/weed/mq/segment/message_serde.go index 66a76c57d..ee55b18a7 100644 --- a/weed/mq/segment/message_serde.go +++ b/weed/mq/segment/message_serde.go @@ -35,7 +35,7 @@ func NewMessageBatchBuilder(b *flatbuffers.Builder, } } -func (builder *MessageBatchBuilder) AddMessage(segmentSeq int64, tsMs int64, properties map[string][]byte, key []byte, value []byte) { +func (builder *MessageBatchBuilder) AddMessage(segmentSeq int64, tsMs int64, properties map[string]string, key []byte, value []byte) { if builder.segmentSeqBase == 0 { builder.segmentSeqBase = segmentSeq } @@ -48,7 +48,7 @@ func (builder *MessageBatchBuilder) AddMessage(segmentSeq int64, tsMs int64, pro var names, values, pairs []flatbuffers.UOffsetT for k, v := range properties { names = append(names, builder.b.CreateString(k)) - values = append(values, builder.b.CreateByteVector(v)) + values = append(values, builder.b.CreateString(v)) } for i, _ := range names { message_fbs.NameValueStart(builder.b) |