How do I decode an Apache Thrift payload in Go?

Question

This is the working JavaScript version of what I'm trying to do in Go.

let next = TBufferedTransport.receiver(data => {

 let proto = new TCompactProtocol(data)
 let ae = new AnalyticEventBatch()

 ae.read(proto)
});

Using Go, I can't get Thrift to decode the payload - what should I be doing?

@voutasaurus i'm receiving the data from Kafka - i don't have control over the transport layer — Rebecca
– Rebecca, Commented Mar 1, 2016 at 18:22

creker · Accepted Answer · 2016-03-01 23:46:58Z

4

var data []byte //that's the byte array you received

transp := &TMemoryBuffer{Buffer: bytes.NewBuffer(data)}
proto := NewTCompactProtocol(transp)

ae := NewAnalyticEventBatch()
ae.Read(proto)

It would be cleaner if you could read from file/socket directly. Then you would only need thrift StreamTransport

edited Mar 1, 2016 at 23:46

answered Mar 1, 2016 at 19:20

creker

9,6101 gold badge33 silver badges49 bronze badges

Sign up to request clarification or add additional context in comments.

1 Comment

Rebecca Over a year ago

You have a small typo: proto := thrift.NewTCompactProtocol(transp), but otherwise this worked perfectly!

Collectives™ on Stack Overflow

How do I decode an Apache Thrift payload in Go?

1 Answer 1

1 Comment

Your Answer

Hot Network Questions

Collectives™ on Stack Overflow

1 Answer 1

1 Comment

Your Answer

Sign up or log in

Post as a guest

Related