Hi all,

 

I am on flink 1.13.2. I set up create table like so:

 

CREATE TABLE lead_buffer (

  `id` INT NOT NULL,

  `state` STRING NOT NULL,

   PRIMARY KEY (`id`) NOT ENFORCED

) WITH (

  'connector'= 'kafka',

  'topic' = 'buffer',

  'format'= 'debezium-avro-confluent',

  'debezium-avro-confluent.schema-registry.url'= 'http://localhost:8081',

  'scan.startup.mode'= 'earliest-offset',

  'properties.group.id' = 'customers',

  'debezium-avro-confluent.basic-auth.user-info' = 'sr-user:sr-user-password',

  'properties.bootstrap.servers'= 'localhost:9092',

  'value.fields-include'= 'EXCEPT_KEY',

  'properties.ssl.endpoint.identification.algorithm'= 'http',

  'properties.security.protocol'= 'SASL_PLAINTEXT',

  'properties.sasl.mechanism'= 'PLAIN',

  'properties.sasl.jaas.config' = 'org.apache.kafka.common.security.plain.PlainLoginModule required username="kafka" password="password";')

 

 

I am looking at the docs here:

 

https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/connectors/table/formats/debezium/#debezium-avro-confluent-basic-auth-user-info

 

According the properties table, there is a property for setting auth to a schema registry: debezium-avro-confluent.basic-auth.user-info. However, when I set this in the DDL for creating the table I get this error:

 

 

Caused by: org.apache.flink.table.api.ValidationException: Unsupported options found for 'kafka'.

 

Unsupported options:

 

debezium-avro-confluent.basic-auth.user-info

 

 

I found “FLINK-22858: avro-confluent doesn't support confluent schema registry that has security enabled”. However that ticket was closed as a duplicate of FLINK-21229, which been resolved and fixed in 1.13.2.

 

Does anyone know if this has been in fact fixed or whether this is user error on my part?

 

Thanks,

Joe

Privileged/Confidential Information may be contained in this message. If you are not the addressee indicated in this message (or responsible for delivery of the message to such person), you may not copy or deliver this message to anyone. In such case, you should destroy this message and kindly notify the sender by reply email. Please advise immediately if you or your employer does not consent to Internet email for messages of this kind. Opinions, conclusions and other information in this message that do not relate to the official business of my firm shall be understood as neither given nor endorsed by it.

Reply via email to