Skip to content
/ avroipc Public

Avroipc is a pure-go-implemented client for flume's avro source

License

Notifications You must be signed in to change notification settings

myzhan/avroipc

Repository files navigation

Build Status Coverage Status

avroipc

Avroipc is a pure-go-implemented client for flume's avro source.

I wrote avroipc to learn avro rpc protocol, and it's not production ready!, use it as you own risk.

Thanks to Linkedin's goavro!

Usage

// flume avro instance address
client := NewClient("localhost:20200")

headersMap := make(map[string]string)
headersMap["topic"] = "myzhan"
headersMap["timestamp"] = "1508740315478"
body := []byte("hello from go")

event := NewEvent(headersMap, body)
client.Append(event)

Development

Clone the repository and do the following sequence of command:

go get
go test ./...

To run test with a real client run the following command:

FLUME_SERVER_ADDRESS=127.0.0.1:20201 go test -count=1 -run TestSend

where 127.0.0.1:20201 is a real Apache Flume server, -count=1 is a way to disable Go build cache.

License

Open source licensed under the MIT license (see LICENSE file for details).

About

Avroipc is a pure-go-implemented client for flume's avro source

Topics

Resources

License

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published

Languages