Details
-
Improvement
-
Status: Resolved
-
P2
-
Resolution: Fixed
-
2.3.0
-
None
Description
Kafka versions 0.10.1 and above have better support for timestamps. We intend to deprecate older versions as a first step towards dropping the support entirely.
The older versions (0.9.x and 0.10.0) at run time still work, but KafkaIO itself does not support these at build time. It lets us remove some of the reflection based code used to support older versions at build time.