Description
Streams does not allow to overwrite some config parameters (eg, enable.auto.commit) Currently, we throw an exception, but this is actually not required, as Streams can just ignore/overwrite the user provided value.
Thus, instead of throwing, we should just log a WARN message and overwrite the config with the values that suits Streams. (atm it's only one parameter enable.auto.commit), but with exactly-once it's going to be more (cf. KAFKA-4923). Thus, the scope of this ticket depends when it will be implemented (ie, before or after KAFKA-4923).
This ticket should also include JavaDoc updates that explain what parameters cannot be specified by the user.
Attachments
Attachments
Issue Links
- is related to
-
KAFKA-4923 Add Exactly-Once Semantics to Streams
- Resolved
- links to