You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Currently, additional properties for the KafkaStreamReader have to be specified with the prefix reader.options. E.g. reader.options.kafka.security.protocol or reader.options.kafka.ssl.key.password
This prefix is inconsistent with all other properties which start with decoder.avro., writer.parquet., manager.checkpoint or transformer.columns.. The properties for the KafkaStreamReader should start with reader.kafka., i.e. reader.kafka.options.kafka.security.protocol.
For additional properties like reader.options.failOnDataLoss or reader.options.minPartitions it's hard to find out which reader implementation they belong to.
Tasks
Change prefix for additional properties for KafkaStreamReader to reader.kafka.options.
How to migrate
All property keys starting with reader.options have to be replaced by reader.kafka.options
The text was updated successfully, but these errors were encountered:
Removed milestone v3.x.0 to reduce number of breaking changes for v3.0.0. This change is not urgent as long as there is no conflict with other readers.
Currently, additional properties for the
KafkaStreamReader
have to be specified with the prefixreader.options.
E.g.reader.options.kafka.security.protocol
orreader.options.kafka.ssl.key.password
This prefix is inconsistent with all other properties which start with
decoder.avro.
,writer.parquet.
,manager.checkpoint
ortransformer.columns.
. The properties for theKafkaStreamReader
should start withreader.kafka.
, i.e.reader.kafka.options.kafka.security.protocol
.For additional properties like
reader.options.failOnDataLoss
orreader.options.minPartitions
it's hard to find out which reader implementation they belong to.Tasks
KafkaStreamReader
toreader.kafka.options.
How to migrate
reader.options
have to be replaced byreader.kafka.options
The text was updated successfully, but these errors were encountered: