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