[jira] [Created] (CALCITE-7773) Kafka adapter should validate class-naming keys in the "consumer.params" operand

["Ruben Q L (Jira)" <ji...@apache.org>]

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)