« Changelog History


Gollum v0.4.4 Release Notes

  • 🚀 This is a patch / minor features release. ⚡️ All vendor dependencies have been updated to the latest version and binaries have been compiled with go 1.7.

    🛠 Fixed with 0.4.4

    • 🛠 Fixed file offset handling in consumer.Kinesis (thanks @relud)
    • 🛠 Fixed producer.File RotatePruneAfterHours setting
    • Producer.File symlink switch is now atomic
    • 🛠 Fixed panic in producer.Redis when Formatter was not set
    • 🛠 Fixed producer.Spooling being stuck for a long time during shutdown
    • 🛠 Fixed native.KafkaProducer to map all topics to "default" if no topic mapping was set
    • 🛠 Fixed a concurrent map write during initialization in native.KafkaProducer
    • 🛠 Fixed consumer.Kafka OffsetFile setting stopping gollum when the offset file was not present
    • consumer.Kafka will retry to connect to a not (yet) existing topic every PersistTimeoutMs
    • Consumer.Kafka now tries to connect every ServerTimeoutSec if initial connect fails
    • 0️⃣ Consumer.Kafka MessageBufferCount default value increased to 8192
    • Producer.Kafka and native.KafkaProducer now discard messages with 0-Byte content
    • 0️⃣ Producer.Kafka SendRetries set to 1 by default to circumvent a reconnect issue within sarama
    • 🛠 Fixed panic in producer.Kafka when shutting down
    • ➕ Added manual heartbeat to check a valid broker connection with producer.Kafka
    • Format.Base64Encode now returns the original message if decoding failed
    • socket.producer TCP can be used without ACK
    • 🛠 Consumer.Syslogd message handling differences between RFC3164 and RFC5424 / RFC6587 fixed

    🆕 New with 0.4.4

    • 🆕 New AWS Firehose producer (thanks @relud)
    • 🆕 New format.ProcessTSV for modifying TSV encoded messages (thanks @relud)
    • ➕ Added user agent parsing to format.ProcessJSON (thanks @relud)
    • ➕ Added support for unix timestamp parsing to format.ProcessJSON (thanks @relud)
    • ➕ Added support for new shard detection to consumer.Kinesis (thanks @relud)
    • ➕ Added support for mulitple messages per record to producer.Kinesis and consumer.Kinesis (thanks @relud)
    • ➕ Added "remove" directive for format.ProcessJSON
    • ➕ Added key Formatter support for producer.Redis
    • ➕ Added RateLimited- metrics for filter.Rate
    • ➕ Added format.Clear to remove message content (e.g. useful for key formatters)
    • ➕ Added "KeyFormatterFirst" for producer.Kafka and native.KafkaProducer
    • ➕ Added Version support for producer.Kafka and consumer.Kafka
    • ➕ Added ClientID support for consumer.Kafka
    • ➕ Added folder creation capatibilites to consumer.File when creating offset files
    • ➕ Added gollum log messages metrics
    • ➕ Added wildcard topic mapping to producer.Kafka and native.KafkaProducer
    • ➕ Added FilterAfterFormat to producer.Kafka and native.KafkaProducer
    • Producer.Spooling now continuously looks for new streams to read
    • Producer.Spooling now reacts on SIGHUP to trigger a respooling
    • 💻 Seperated version information to -r (version, go runtime, modules) and -v (just version) command line flag
    • ➕ Added trace commandline flag