[jira] [Updated] (FLINK-33124) Kafka Connector not working for table

["Aarsh Shah (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLINK-33124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Aarsh Shah updated FLINK-33124:
-------------------------------
          Component/s: Connectors / Kafka
                       Table SQL / Runtime
    Affects Version/s: 1.16.0
          Description: 
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'

> 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)