Release 0.6.3 - 2017/11/14 * in_kafka_group: re-create consumer when error happens during event fetch Release 0.6.2 - 2017/11/1 * Fix ltsv parsing issue which generates symbol keys Release 0.6.1 - 2017/08/30 * Add stats and datadog monitoring support * ssl_ca_certs now accepts multiple paths * Fix bug by ruby-kafka 0.4.1 changes * Update ruby-kafka dependency to v0.4.1 Release 0.6.0 - 2017/07/25 * Add principal and keytab parameters for SASL support Release 0.5.7 - 2017/07/13 * out_kafka_buffered: Add kafka_agg_max_messages parameter Release 0.5.6 - 2017/07/10 * output: Add ActiveSupport notification support Release 0.5.5 - 2017/04/19 * output: Some trace log level changed to debug * out_kafka_buffered: Add discard_kafka_delivery_failed parameter Release 0.5.4 - 2017/04/12 * out_kafka_buffered: Add max_send_limit_bytes parameter * out_kafka: Improve buffer overflow handling of ruby-kafka Release 0.5.3 - 2017/02/13 * Relax ruby-kafka dependency Release 0.5.2 - 2017/02/13 * in_kafka_group: Add max_bytes parameter Release 0.5.1 - 2017/02/06 * in_kafka_group: Fix uninitialized constant error Release 0.5.0 - 2017/01/17 * output: Add out_kafka2 plugin with v0.14 API Release 0.4.2 - 2016/12/10 * input: Add use_record_time and time_format parameters * Update ruby-kafka dependency to 0.3.16.beta2 Release 0.4.1 - 2016/12/01 * output: Support specifying partition Release 0.4.0 - 2016/11/08 * Remove zookeeper dependency Release 0.3.5 - 2016/10/21 * output: Support message key and related parameters. #91 Release 0.3.4 - 2016/10/20 * output: Add exclude_topic_key and exclude_partition_key. #89 Release 0.3.3 - 2016/10/17 * out_kafka_buffered: Add get_kafka_client_log parameter. #83 * out_kafka_buffered: Skip and log invalid record to avoid buffer stuck. #86 * in_kafka_group: Add retry_emit_limit to handle BufferQueueLimitError. #87 Release 0.3.2 - 2016/10/06 * in_kafka_group: Re-fetch events after consumer error. #79 Release 0.3.1 - 2016/08/28 * output: Change default required_acks to -1. #70 * Support ruby version changed to 2.1.0 or later Release 0.3.0 - 2016/08/24 * Fully replace poseidon ruby library with ruby-kafka to support latest kafka versions See git commits for older changes