Agis Anastasopoulos
Agis Anastasopoulos
The Go driver is able to report stats events that we could expose to clients (see https://github.com/confluentinc/confluent-kafka-go/commit/18b5a55f7ee663a3fc44a42ca937ed276de529d0). This will be useful for monitoring Rafka (eg. monitor lagging consumers). To begin...
When we build with `make build`, the sha1 of the tip is appended to the version displayed when doing `rafka -version`. However, the debian package doesn't contain this info. I...
This is to verify that the servers shuts down successfully.
This could help in debugging. Maybe we can do this with `SETNAME`
Example: https://travis-ci.org/skroutz/rafka/builds/394071204
Now that the vgo proposal is [accepted](https://github.com/golang/go/issues/24301), it might make sense to give it a try.
```shell agis:rafka [master] $ go test -args -kafka kafka.json.sample [rafka] 2017/08/25 17:59:54 Spawning Consumer Manager (librdkafka 0.11.0) | config: {0.0.0.0 6382 {map[session.timeout.ms:6000 log.connection.close:false api.version.request:true bootstrap.servers:kafka-1.example.com,kafka-2.example.com] map[enable.auto.commit:false bootstrap.servers:kafka-1.example.com,kafka-2.example.com session.timeout.ms:6000 go.events.channel.enable:false go.application.rebalance.enable:false...
Many times we need to just assign a consumer to a particular topic, without having to consume from it. Tests is a place where this comes up frequently. We could...
Doing a `$ go run test.go` gives the following output: ``` 2013-09-21 23:06:54.233 test[81015:303] *** Terminating app due to uncaught exception 'NSInternalInconsistencyException', reason: 'Error (1000) creating CGSWindow on line 259'...
This patch adds supports for skipping loading the `.env` file, by setting the HIVEMIND_SKIP_ENV environment variable. For example: $ HIVEMIND_SKIP_ENV=1 hivemind Resolves #28.