Ruben Q L created CALCITE-7773:
----------------------------------
Summary: Kafka adapter should validate class-naming keys in the
"consumer.params" operand
Key: CALCITE-7773
URL: https://issues.apache.org/jira/browse/CALCITE-7773
Project: Calcite
Issue Type: Improvement
Components: kafka-adapter
Reporter: Ruben Q L
Assignee: Mingmin Xu
Fix For: 1.43.0
The Kafka adapter's {{consumer.params}} model operand is forwarded verbatim to
{{KafkaConsumer}} in {{KafkaTableFactory.create(...)}}. Several Kafka consumer
configuration keys cause the client to load and instantiate classes named in
the operand as part of {{new KafkaConsumer<>(config)}}.
CALCITE-7770 handled the same situation for {{consumer.cust}} and
{{row.converter}}, so a similar hardening should be applied on
{{consumer.params}}.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
