Proto commits in mailgun/kafka-pixy

These 18 commits are when the Protocol Buffers files have changed:

Commit:631041c
Author:Maxim Vladimirskiy

Replace github.com/golang/protobuf with google.golang.org/protobuf

The documentation is generated from this commit.

Commit:6c38aab
Author:Maxim Vladimirskiy
Committer:Maxim Vladimirskiy

Switch to go mod

Commit:60a2ced
Author:Bryan Baugher

Added java options to protobuf file

Commit:2c1fd5e
Author:Maxim Vladimirskiy
Committer:Maxim Vladimirskiy

Update dependencies

Commit:2ab548d
Author:Evan Broder
Committer:Evan Broder

Add support for Kafka record headers This adds support for specifying and receiving Kafka record headers (added in Kafka 0.11) to both the HTTP and gRPC interfaces. For gRPC headers are simply added as an additional field to the ProdRq and ConsRs structs - easy. For consuming over HTTP, they're added as an additional field - also easy. For producing over HTTP, the HTTP server looks for any HTTP header with the prefix "X-Kafka-". It strips that prefix to get the Kafka record header key, and treats the HTTP header value as a base 64 encoded value.

Commit:edd5985
Author:Maxim Vladimirskiy
Committer:Maxim Vladimirskiy

Update google.golang.org/grpc to v1.9.2

Commit:6faa695
Author:Maxim Vladimirskiy
Committer:Maxim Vladimirskiy

Update golang/protobuf to v1.0.0

Commit:144a5f6
Author:Derrick J. Wippler

Added missing admin methods to GRPC interface

Commit:e8c0b4d
Author:Maxim Vladimirskiy
Committer:Maxim Vladimirskiy

Fix shutdown logic We used to shutdown API servers first. But that makes it impossible to receive acks for offered messages. So the shutdown procedure was changed to be: 1. Gracefully shutdown proxies, while waiting for acks the will reject produce/consume requests with Service Unavailable response; 2. Shutdown all API servers;

Commit:84544ea
Author:Maxim Vladimirskiy
Committer:Maxim Vladimirskiy

Upgrade google.golang.org/grpc to v1.6.0

Commit:f59ec66
Author:Maxim Vladimirskiy
Committer:Maxim Vladimirskiy

Move expiration logic to topic consumer

Commit:5a58145
Author:Maxim Vladimirskiy

Add quick-start-python.md guide (fixes #106)

Commit:c029e48
Author:Derrick J. Wippler
Committer:Derrick J. Wippler

Added GRPC support for fetching offsets

Commit:2c8c35a
Author:Maxim Vladimirskiy
Committer:Maxim Vladimirskiy

Fix README typos

Commit:faf4d93
Author:Maxim Vladimirskiy

Rename API methods to improve clarity

Commit:9aff44c
Author:Maxim Vladimirskiy

Add comments to grpc.proto

Commit:fd7c509
Author:Maxim Vladimirskiy

Expose acks in API

Commit:70fcd05
Author:Maxim Vladimirskiy

Add gRPC interface