[
https://issues.apache.org/jira/browse/FLINK-33124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17770279#comment-17770279
]
Martijn Visser commented on FLINK-33124:
----------------------------------------
[~aarsh33] This all depends on what's necessary in your configuration to
authorize towards your Kafka cluster. If you have a setup that doesn't require
a truststore, you don't have to provide it.
> Kafka Connector not working for table
> -------------------------------------
>
> Key: FLINK-33124
> URL: https://issues.apache.org/jira/browse/FLINK-33124
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Kafka, Table SQL / Runtime
> Affects Versions: 1.16.0
> Reporter: Aarsh Shah
> Priority: Major
>
> The kafka table connector is not working for table
> [As mentioned
> here|https://nightlies.apache.org/flink/flink-docs-release-1.16/docs/connectors/table/kafka/#security],
> I am providing the mechanism, the protocol and the jaas config, but the
> server doesn't have a truststore, so is it mandatory to provide the
> truststore?
> And if not, what am I missing
> This is my command
> CREATE TABLE IF NOT EXISTS `xyz` (
> proctime AS PROCTIME()
> ) WITH (
> 'connector' = 'kafka',
> 'topic' = 'xyz',
> 'scan.startup.mode' = 'group-offsets',
> 'properties.auto.offset.reset' = 'earliest',
> 'properties.security.protocol' = 'SASL_SSL',
> 'properties.sasl.mechanism' = 'SCRAM-SHA-256',
> 'properties.sasl.jaas.config' =
> 'org.apache.kafka.common.security.scram.ScramLoginModule required
> username="xyz" password="xyz";',
> 'properties.bootstrap.servers' = 'xyz',
> 'properties.group.id' = 'xyz',
> 'format' = 'protobuf',
> 'protobuf.message-class-name' = 'xyz'
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
