Kafka Streams - 2305 (EEP 8.1.1) 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 May 2023
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 - 2305 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
10b2a4a188 2023-05-04 KAFKA-676 Upgrade reflections library back to 0.9.12
106e6bf371 2023-05-03 KAFKA-937 Update Jetty to 9.4.51.v20230217
c1a4673c46 2023-04-03 ECO-284 Security:: CVE:: Vulnerable version of jackson-databind bundled as part of MEP 9.1.1 -> Kafka binaries.
60c052690b 2021-05-21 KAFKA-12820: Upgrade maven-artifact dependency to resolve CVE-2021-26291
f656e927c7 2020-12-10 MINOR: remove duplicate code from resetByDuration (#9699)
4965b9defb 2021-04-12 KAFKA-9527: fix NPE when using time-based argument for Stream Resetter Tool (#10042)
7b752b5494 2022-09-13 KAFKA-908 Vulnerable bc-fips-
c81bc90a57 2022-09-07 KAFKA-905 CVE-2019-17571
19ab9334a7 2022-09-02 KAFKA-904 Fix CVE-2020-36518 for MEP-8.1.0
cb67728a90 2022-08-19 KAFKA-899 CVE-2021-29425 - commons-io
8cd2955779 2022-06-27 MS-1082 Make ListConsumerGroupOffsetsResult constructor accessible from outside the package.
93781bd35d 2021-06-18 KAFKA-885 Fix CVE-2021-38153
9ddc2e3ef2 2022-06-10 KAFKA-856 Ignore org.apache.kafka.streams.state.internals.RocksDBStoreTest#shouldThrowProcessorStateExceptionOnOpeningReadOnlyDir()
c4c324156d 2022-06-09 KAFKA-875 Adapt unit tests to mapr default value of group.id
d719ccbbbc 2022-06-02 KAFKA-880 Kafka broker cannot authenticate to ZK node with core7.0
5895a146c7 2022-05-27 KAFKA-865 Add mapr-specific javadoc to Admin#listOffsets (#254)
3a1821912c 2022-05-25 KAFKA-856 Run Kafka Client unit tests as a part or releaseTarGz goal (adapt tests) (#253)
49a16477f0 2022-05-25 EEP-KAFKA-849 kafka client crashes with NPE while trying to use SSL (defaults defined 2)
b0f288d5ff 2022-05-24 KAFKA-878 Add required apache initialization in KafkaProducer (#252)
f18dd54378 2022-05-24 KAFKA-877 Restore change from KAFKA-6180 (#251)
0d9c3487ca 2022-05-24 KAFKA-876 Get rid of deprecated ExtendedSerializer and ExtendedDeserializer (#250)
57f3262af5 2022-05-23 KAFKA-874 Add groupId validation and NPE protection to commitAsync() (#248)
f8a2387b2c 2022-05-23 KAFKA-873 Remove useless validation in apache mode initialization (#247)
cff0f2e87f 2022-05-23 KAFKA-872 Remove KAFKA-392 changes from apache code (#246)
80dc911b1c 2022-05-23 KAFKA-871 Subscribe and assign to empty list should be treated as unsubscribe() (#245)
e20485d2e8 2022-05-23 KAFKA-870 Some close() methods are not actually executed when closing consumer/producer in apache kafka mode (#244)
794d984917 2021-07-20 MINOR: Fix `testResolveDnsLookup` by using a mocked dns resolver (#11091)
e381e1e607 2021-02-05 KAFKA-12193: Re-resolve IPs after a client disconnects (#9902) (#10061)
a791e49df2 2021-06-28 KAFKA-12790: Remove SslTransportLayerTest.testUnsupportedTlsVersion (#10922)
5d2a6b1755 2021-07-20 MINOR: Fix testTlsDefaults failure due to TLS 1.0/1.1 being disabled (#11092)
7240c17852 2022-05-18 KAFKA-866 KafkaMaprStreams#getShortTopicNameFromFullTopicName should do nothing if topic name is already short (#242)
9287e2c952 2022-04-11 KAFKA-854 Add metrics support (#237)
3b507fab20 2022-03-25 EEP-KAFKA-849 kafka client crashes with NPE while trying to use SSL
097ec06c3c 2022-02-15 KAFKA-848 Missing dependencies were added
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.