Skip to content

v0.9.3
Compare
Choose a tag to compare
@edenhill edenhill released this 23 Jan 17:23
· 2753 commits to master since this release
v0.9.3
2f153ea

Maintenance release

Enhancements

  • Increase .._TOPICS_MAX to 1M
  • Add cgrp stats: rebalance_age, rebalance_cnt, assignment_size
  • win32: allow the use of LIBRDKAFKA_STATICLIB to enable static library (#905, @skarlsson)
  • C++: Add support for setting "consume_cb" in Conf with a RdKafka::ConsumeCb and proper handling of that callback object by the underlying C library. (#741, @lambdaknight)
  • Added socket.nagle.disable to disable the Nagle algorithm (#862)
  • Added rd_kafka_topic_partition_list_sum()
  • Added connect_cb and closesocket_cb to conf

Fixes

  • Fix relative offset calculation (#859, @yunjing)
  • cgrp: dont get stuck in wait-coord state on reoccuring query errors (issue #844)
  • cgrp: fix a number of assign() problems (issues #871, #844, possibly #730)
  • cgrp: increased robustness for wait_commit et.al (#785)
  • cgrp: time out ops in wait_coord queue (#785)
  • cgrp: do async termination by state to avoid recursive locks from timeout_scan
  • Dont store initial offset in fetch_start0 (#742)
  • Win32 compilation and linking fixes
  • queue.buffering.max.kbytes wrapped on platforms with 32-bit size_t (#998)
  • Timeout was not enforced in flush()
  • librdkafka++: just link C library, not also its dependencies
  • rdkafka_performance: fix multi -p partitions allocation error and memory leak
  • Fix ApiVersionRequest timeout (10s)
  • rd_kafka_q_concat: fix erroneous unlock() on enq failure
  • C++: Added TopicPartition::create(, ..offset)
  • C++: Fix undefined references to static const ints (#961, #962, @bbfgelman1)
  • Dont start SASL for the internal broker (#968)
  • Proper suppression of connect failure logs (#847)
  • Proper ATOMIC_OPn (#708)
  • fix: use out of scope variable (#974, @HeChuanXUPT)
  • INTRODUCTION: fix wrong batch.num.messages default value (#924)
  • configure: check for library headers too (fixes OpenSSL failures on OSX)
  • mklove: lib_check now attempts compilation after pkg-config passed (for false positive of SSL on OSX)
  • mklove: fix ./configure --reconfigure
  • stats: fix brokers.toppars key duplication
  • consumer: Correctly set timestamp for compressed messages (#858)
  • Dont attempt SASL auth with broker-unsupported mechs (issue #907)
  • consumer_poll() without a valid group.id would return a broken message_t
  • Fix duplicate desired_link calls (crash or memory leak)
  • Fix for async offset commit issue on AIX (#852, @asharma339)
  • _builtin.. replacements for native toolchains on sun and aix (#865, @asharma339)
  • Add snappy function prefix to avoid symbol collision with google snappy (#880, @hustlijian)
  • toppars: Dont mix up UNKNOWN / DESIRED flags
  • Use compiler specific atomic ops for sun studio compiler (#869, @asharma339)
  • fix bug rd_kafka_timer_t microsecond interval overflow. (#870, @lvxv)
  • Set HeartbeatRequest timeout to session.timeout.ms
  • Allow max one HeartbeatRequest in transit
  • DescribeGroups: Avoid zero-byte allocations (for AIX)
  • fix func rd_kafka_new declare use_conf but not use cause conf->socket_cb segmentfault (#863) (@wadee)
Assets 2
Loading