CDH 6 includes Apache Kafka as part of the core package. The documentation includes improved contents for how to set up, install, and administer your Kafka ecosystem. For more information, see the Cloudera Enterprise 6.0.x Apache Kafka Guide. We look forward to your feedback on both the existing and new documentation.

Issues Fixed in CDK 2.0.1 Powered By Apache Kafka

  • KAFKA-3409: MirrorMaker hangs indefinitely due to commit.
  • KAFKA-3378: Client blocks forever if SocketChannel connects instantly.
  • KAFKA-3426: Improve protocol type errors when invalid sizes are received.
  • KAFKA-3330: Truncate log cleaner offset checkpoint if the log is truncated.
  • KAFKA-3463: Change default receive buffer size for consumer to 64K.
  • KAFKA-1148: Delayed fetch/producer requests should be satisfied on a leader change.
  • KAFKA-3352: Avoid DNS reverse lookups.
  • KAFKA-3341: Improve error handling on invalid requests.
  • KAFKA-3310: Fix for NPEs observed when throttling clients.
  • KAFKA-2784: swallow exceptions when MirrorMaker exits.
  • KAFKA-3243: Fix Kafka basic ops documentation for MirrorMaker, blacklist is not supported for new consumers.
  • KAFKA-3235: Unclosed stream in AppInfoParser static block.
  • KAFKA-3147: Memory records is not writable in MirrorMaker.
  • KAFKA-3088: Broker crash on receipt of produce request with empty client ID.
  • KAFKA-3159: Kafka consumer client poll is very CPU intensive under certain conditions.
  • KAFKA-3189: Kafka server returns UnknownServerException for inherited exceptions.
  • KAFKA-3157: MirrorMaker does not commit offset with low traffic.
  • KAFKA-3179: Kafka consumer delivers message whose offset is earlier than sought offset.
  • KAFKA-3198: Ticket Renewal Thread exits prematurely due to inverted comparison.