hashmapinc / hashmapinc/Tempus
Upgrade Kafka Version to 0.11.0
Open
Complete
Tempus/Application
- Dominant language
- Java
- Stars
- 32
- Forks
- 11
- PR merge metrics
- No merged PRs in 30d
Description
Currently Tempus Kafka server extensions are built against Kafka version 0.9.0 (Scala 2.10). As a result the Kafka-Plug-in Producer works with 0.9.0.
From 0.10.0 Kafka brokers add a time stamp to each message (representing ingestion time). As a result messages published with older versions of Kafka can't be consumed by Kafka-Streams 0.10.x (which is our development/production environment).
It is therefore required to upgrade Tempus Kafka versions to 0.10.0. (Scala 2.11). This needs change in tempus/pom/xml as well as extensions-kafka/pom.xml.
Contributor guide
No contributing guide indexed for this repository
Assessment
This issue has not been assessed yet.