« Changelog History


Gollum v0.4.3 Release Notes

  • 🚀 This is a patch / minor features release. 🔧 It includes several configuration changes for producer.Kafka that might change the runtime behavior. 🔧 Please check your configuration files.

    🛠 Fixed with 0.4.3

    • 🛠 Fixed several race conditions reported by Go 1.6 and go build -race
    • 🛠 Fixed the scribe producer to drop unformatted message in case of error
    • 🛠 Fixed file.consumer rotation to work on regular files, too
    • 🛠 Fixed file.consumer rotation to reset the offset file after a SIGHUP
    • ⚡️ Dockerfiles updated
    • 🐎 Producer.Kafka now sends messages directly to avoid sarama performance bottlenecks
    • 0️⃣ consumer.Kafka offset file is properly read on startup if DefaultOffset "oldest" or "newest" is
    • 👍 Exisiting unix domain socket detection changed to use create instead of stat (better error handling)
    • ⚡️ Kafka and Scribe specific metrics are now updated if there are no messages, too
    • 👍 Scribe producer is now reacting better to server connection errors
    • ✅ Filters and Formatters are now covered with unittests

    🆕 New with 0.4.3

    • 👌 Support for Go1.5 vendor experiment
    • 🆕 New producer for librdkafka (not included in standard builds)
    • Metrics added to show memory consumption
    • 🆕 New kafka metrics added to show "roundtrip" times for messages
    • producer.Benchmark added to get more meaningful core system profiling results
    • 🆕 New filter filter.Rate added to allow limiting streams to a certain number of messages per second
    • ➕ Added key support to consumer.Kafka and producer.Kafka
    • ➕ Added an "ordered read" config option to consumer.Kafka (round robin reading)
    • ➕ Added a new formater format.ExtractJSON to extract a single value from a JSON object
    • 🖨 Go version is now printed with gollum -v
    • Scribe producer now queries scribe server status in regular intervals
    • 🔧 format.Sequence separator character can now be configured
    • 🔧 format.Runlength separator character can now be configured

    Other changes with 0.4.3

    • 📇 Renamed producer.Kafka BatchTimeoutSec to BatchTimeoutMs to allow millisecond based values
    • producer.Kafka retry count set to 0
    • 0️⃣ producer.Kafka default producer set to RoundRobin
    • 0️⃣ producer.Kafka GracePeriodMs default set to 100
    • 📇 producer.Kafka MetadataRefreshMs default set to 600000 (10 minutes)
    • 0️⃣ producer.Kafka TimeoutMs default set to 10000 (10 seconds)
    • filter.RegExp FilterExpressionNot is evaluated before FilterExpression
    • filter.RegExp FilterExpression is evaluated if FilterExpressionNot passed