0.8.3

New features and enhancements:

• Added fetch.message.max.bytes and receive.message.max.bytes properties.
• Added rd_kafka_errno2err() for converting errno to proper rdkafka errors (issue #39)
• Trigger RD_KAFKA_RESP_ERR__ALL_BROKERS_DOWN error when all brokers are down (issue #64)
• Immediate failure on unknown topic (issue #39)
• rdkafka_example: Added raw output (-A) and quiet (-q) options, suitable for generic output to other programs.
• Added "rxcorriderrs" to stats output (unknown correlation ids)

Fixes:

• Receiving from multiple well fed partitions will no longer cause "Invalid message size .." errors.
• Topic refcount fix - rdkafka would not fully terminate under some circumstances (issue #72)
• rd_kafka_wait_destroyed() now also waits for all rk's to go away.
• Fix Cygwin compilation, again
• Proper errcode for broker transport failures, not just __FAIL (issue #64)
• Fixed out-of-order problem for produced messages under some circumstances
• Internal topic count was not properly decreased on topic destroy
• Plugged memory leak on exit: internal broker ops queue
• Added friendly hint when message.max.bytes is configured too low.
• Fixed duplicate broker names in broker fail logs
• message.send.max.retries did not have effect, no messages were retried (for issue #74)
• Avoid flooding the broker with topic-specific metadata requests when produce fails

0.8.2

New features:

• Added automatic consumer offset management (local file)
• The application no longer needs to install a SIGPIPE handler
• Added more configuration API functions (copy, destroy, dump, ...)
• examples: Added support for canonical "end","beginning","stored" to -o offset arg
• rdkafka_example: Added -X prop=val
• Now builds on MacOSX 10.9
• Now builds on RHEL 5
• Now builds on Cygwin
• Added -I (idle) switch to rdkafka_performance

Fixes:

• Proper librdkafka.a dependency for examples
• Added 'make check' target to check availability of all build artifacts
• Dont attempt to gzip compress 0 length message chunks (issue #60)
• The application no longer needs to install a SIGPIPE handler
• Compilation warning fixes on various platforms and gcc versions
• Allow producing and consuming empty messages (issue #60)
• rdkafka_performance: -X topic... properties did not work
• Fixed decoding of snappy-java compression framing (issue #55)
• Fixed flaky Gzip decompression (issue #54)
• Fail messages for unknown partitions immediately (issue #39)
• Clarify available compression support (none, gzip, snappy)
• Allow NULL 'conf' argument to rd_kafka_topic_new()
• Use 'void *' for produce payload type instead of 'char *'
• rdkafka_performance: Count immediate produce() failures as failed messages too
• Handle per topic+partition produce errors (issue #40)
• Print error string, not number, in metadata request failure log message
• Only generate statistics if statistics.interval.ms is non-zero
• Correctly calculate number of topics for filtered Metadata requests

0.8.1

Bugfix and enhancement release.

Bugfixes:

• Correctly handle IPv6 broker addresses added by application (issue #23)
• Let produce API honour "message.max.bytes" (issue #24)
• Dont re-query metadata immediately if leader was lost (issue #28)
• Fixed recursive locking on broker fail+buf retry (issue #27)
• Compilation warning fixes on various platforms and setups
• Dont reuse broker ERR_REQUEST_TIMED_OUT if timeout was local.

Enhancements:

• rdkafka_performance consumer: call poll to handle stats callbacks.
• Reformatted stats JSON output not to contain arrays
• Added broker request RTT statistic
• Added rd_kafka_version() and rd_kafka_version_str()
• Added socket.send.buffer.bytes and socket.receive.buffer.bytes configuration properties

0.8.0

Full support for Apache Kafka 0.8:

• producer
• consumer
• compression
• broker failover support
• message reliability
• high performance