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 1.3.2 Powered By Apache Kafka

  • KAFKA-1057: Trim whitespaces from user specified configs
  • KAFKA-1641: Log cleaner exits if last cleaned offset is lower than earliest offset
  • KAFKA-1702: Messages silently lost by the (old) producer
  • KAFKA-1758: corrupt recovery file prevents startup
  • KAFKA-1836: metadata.fetch.timeout.ms set to zero blocks forever
  • KAFKA-1866: LogStartOffset gauge throws exceptions after log.delete()
  • KAFKA-1883: NullPointerException in RequestSendThread
  • KAFKA-1896: Record size function of record in mirror maker hit NPE when the message value is null.
  • KAFKA-2012: Broker should automatically handle corrupt index files
  • KAFKA-2096: Enable keepalive socket option for broker to prevent socket leak
  • KAFKA-2114: Unable to set default min.insync.replicas
  • KAFKA-2189: Snappy compression of message batches less efficient in 0.8.2.1
  • KAFKA-2234: Partition reassignment of a nonexistent topic prevents future reassignments
  • KAFKA-2235: LogCleaner offset map overflow
  • KAFKA-2336: Changing offsets.topic.num.partitions after the offset topic is created breaks consumer group partition assignment
  • KAFKA-2393: Correctly Handle InvalidTopicException in KafkaApis.getTopicMetadata()
  • KAFKA-2406: ISR propagation should be throttled to avoid overwhelming controller
  • KAFKA-2407: Only create a log directory when it will be used
  • KAFKA-2437: Fix ZookeeperLeaderElector to handle node deletion correctly
  • KAFKA-2468: SIGINT during Kafka server startup can leave server deadlocked
  • KAFKA-2504: Stop logging WARN when client disconnects