Kafka Streams - 2201 (EEP 8.1.0) Release Notes

The notes below relate specifically to the HPE Ezmeral Data Fabric Distribution for Apache Kafka. See Apache Kafka 2.6.1 release notes or the Apache Kafka Streams homepage for more information.
Release Date January 2022
HPE Version Interoperability See EEP Components and OS Support.
Source on GitHub https://github.com/mapr/kafka
GitHub Release Tag
Maven Artifacts https://repository.mapr.com/maven/
Package Names See Package Names for Ecosystem Packs (EEPs).

New in This Release

Kafka Streams - 2201 introduces the following enhancements or HPE platform-specific behavior changes:
  • CVE fixes
  • Bug fixes


This HPE release includes the following fixes on the base release:
GitHub Commit Number



MapR Fix Number and Description
0d14450 2022-01-25 MAPR-KAFKA-839 Updated log4j version to 1.3.1-mapr
20b0965 2022-01-12 MAPR-KAFKA-771 Make ListConsumerGroupsResult constructor accessible from outside the package.
cabe9f4 2021-12-16 MAPR-KAFKA-826 Added force override of log4j version
6b76e00 2021-12-15 MAPR-KAFKA-826 Updated log4j version
f59ab85 2021-11-19 MAPR-KAFKA-800 Skip already existing stream creation
17e8dbe 2021-11-19 MAPR-KAFKA-804 Netty CVE for kafka components
022472e 2021-11-16 MAPR-KAFKA-786 Added publishing of kafka-streams-test-utils
7a256fd 2021-11-15 MAPR-KAFKA-799 Backport KAFKA-12211 NoSuchFileException will be thrown if hasPersistentStores is false when creating stateDir
8e73665 2021-11-11 MAPR-KAFKA-796 Update dependencies versions for MEP-8.1



MAPR-KAFKA-793 KafkaProducer throws NPE to spring-kafka (additional commit)

44b509a 2021-11-08 MAPR-KAFKA-793 KafkaProducer throws NPE to spring-kafka
For complete details, refer to the commit log for this project in GitHub.

Known Issues and Limitations

  • Transactions are not supported.
  • Pattern subscription is not supported.
  • The application reset tool hangs if it runs when the Kafka Streams application is running.
  • The application reset tool may throw a Null Pointer Exception when the date or duration parameter is used.
  • The application reset tool does not reset to intermediate offset if the topic has multiple partitions.
  • MAPR-KAFKA-581: Stream hangs in rebalancing state. The workaround is to set a larger timeout. This issue is caused by MS-915: “MapR Stream application hangs inside cycle”

Resolved Issues

  • None.