Issues Fixed in Cloudera Distribution of Apache Kafka 2.1.0

  • KAFKA-3787: Preserve the message timestamp in MirrorMaker
  • KAFKA-3789: Upgrade Snappy to fix Snappy decompression errors
  • KAFKA-3802: Log mtimes reset on broker restart or shutdown
  • KAFKA-3894: Log cleaner can partially clean a segment
  • KAFKA-3915: Do not convert messages from v0 to v1 during log compaction
  • KAFKA-3933: Always fully read deepIterator
  • KAFKA-3950: Only throw authorization exception if pattern subscription matches topic
  • KAFKA-3977: Defer fetch parsing for space efficiency and to ensure exceptions are raised to the user
  • KAFKA-4050: Allow configuration of the PRNG used for SSL
  • KAFKA-4073: MirrorMaker should handle messages without timestamp correctly

Cloudera Distribution of Apache Kafka 2.1.0 is rebased on Apache Kafka 0.10. For a complete list of fixed issues, see