Changelog

Version 5.1.0

  • PR-511 - CPKAFKA-1876: Log cause of failure to produce messages in tests
  • PR-512 - Fix race condition when expiration thread iterates over partially-initialized consumer
  • PR-503 - Fix location of jars for dev testing
  • PR-481 - CPKAFKA-1681: Add long polling functionality
  • PR-508 - CPKAFKA-1868: Add more consumer tests
  • PR-507 - CPKAFKA-1871: Fix problem where ReadTaskSchedulerThread would loop too often
  • PR-504 - CPKAFKA-1865: Performance degrades drastically after running for extended periods
  • PR-495 - CPKAFKA-1794: Assign leader ID -1 on offline partitions in the topic describe API
  • PR-477 - Fix SimpleConsumerManager properly return requested offsets for compressed topic
  • PR-474 - MINOR: Fix checkstyle path
  • PR-466 - Change Consumer threading model to better handle rebalances
  • PR-459 - MINOR: Add utility createConsumerProperties() test method since it was removed from AK
  • PR-452 - Fix checkstyle to pass on 8.5 after upgrade from 6.19
  • PR-439 - Temporarily pin Kafka and Confluent versions
  • PR-438 - Don't use deprecated RecordMetadata constructor

Version 5.0.0

  • PR-439 - Temporarily pin Kafka and Confluent versions
  • PR-438 - Don't use deprecated RecordMetadata constructor
  • PR-434 - Fix usage of internal Jersey utilities that no longer exist
  • PR-428 - Use ExplicitGCInvokesConcurrent instead of disabling explicit GC

Version 3.3.0

  • PR-305 - Use max.block.ms instead of metadata.fetch.timeout.ms since the latter was deprecated and now removed in KAFKA-3763
  • Ability to add resources like filter through a custom extension and provide a custom context
  • PR-296 - Interceptor configuration options

Version 3.2.2

  • PR-303 - CLIENTS-304: Fix AvroConsumerRecord constructors and handling of topic for v1 consumer API.

Version 3.2.1

  • PR-285 - CLIENTS-281: Fix KafkaConsumerReadTask's locking, handling of multiple polls, invalid handling of old ConsumerTimeout exceptions, and incorrect generic type parameters.
  • PR-277 - Documentation fixes

Version 3.2.0

  • PR-256 - Update ClusterTestHarness to use o.a.k.common.utils.Time.
  • PR-255 - clarified the key/value format limitations based on user questions
  • PR-264 - Fix build to work post KIP-103
  • PR-265 - Follow up for KIP-103 changes that fixes ProducerPool's extraction of endpoints to use the security protocol in the URL instead of the listener name.
  • PR-268 - modified readme to use v2. also bumped installation up for usability
  • PR-271 - Updated quickstart and configuration docs for V2 and for security
  • PR-258 - REST Proxy security
  • PR-274 - added field 'topic' to tools/ConsumerPerformance.java for system test
  • PR-272 - added description of JVM parameters for SASL configuration

Version 3.1.2

No changes

Version 3.1.1

No changes

Version 3.1.0

  • PR-239 - Require bash since we use some bashisms and fix a copyright.
  • PR-235 - fix typo command line options -help check
  • PR-222 - fixing issue #91
  • PR-230 - Issue #229: Add blurb on Jetty jmx metrics
  • PR-214 - Small readme.md fix
  • PR-127 - Fix to ConsumerManager tests AND then handling of max bytes
  • PR-203 - Fix a typo that cause non-corresponding logger name
  • PR-202 - fix the implementation of topicExists

Version 3.0.0

  • PR-164 - 2.x merge to master
  • PR-166 - Bump version to 3.0.0-SNAPSHOT and Kafka dependency to 0.10.0.0-SNAPSHOT
  • PR-171 - Fix build to handle rack aware changes in Kafka.
  • PR-174 - Update CoreUtils usage to match kafka updates
  • PR-189 - Minor fixes for compatibility with newest 0.10.0 branch.
  • PR-192 - Minor fixes for compatibility with newest 0.10.0 branch.
  • PR-202 - fix the implementation of topicExists
  • PR-205 - Rearrange quickstart and use topics from earlier steps in requests for metadata so the example output will exactly match real output when starting from an empty cluster.

Version 2.0.1

  • PR-144 - Fix for Race condition when consuming while topic is being created (Issue #105)
  • PR-158 - Update Kafka version to 0.9.0.1-cp1

Version 2.0.0

  • PR-64 - Reduce integration test time.
  • PR-66 - Add support for SimpleConsumer-like access (Issue #26)
  • PR-67 - Handle conflicting IDs and separate IDs used in the REST Proxy and by Kafka's consumer implementation.
  • PR-78 - Remove kafka from list of production directories to include in CLASSPATH.
  • PR-89 - JSON message support
  • PR-96 - Fixed log4j and daemon flag bugs in kafka-rest-run-class based on fix from schema-registry.
  • PR-99 - Require Java 7
  • PR-101 - rest-utils updates
  • PR-103 - Issue 94 rename main
  • PR-108 - Clarify partitioning behavior for produce requests
  • PR-117 - Update to Kafka 0.9.0.0-SNAPSHOT and make adjustments to work with updated ZkUtils.
  • PR-122 - Use x.y.z versioning scheme (i.e. 2.0.0-SNAPSHOT)
  • PR-123 - Updated args for JaasUtils.isZkSecurityEnabled()
  • PR-125 - Use Kafka compiled with Scala 2.11