You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "songwenbin (Jira)" <ji...@apache.org> on 2022/11/18 01:02:00 UTC
[jira] [Updated] (FLINK-28672) properties.allow.auto.create.topics disable
[ https://issues.apache.org/jira/browse/FLINK-28672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
songwenbin updated FLINK-28672:
-------------------------------
Summary: properties.allow.auto.create.topics disable (was: properties.allow.auto.create.topics无效)
> properties.allow.auto.create.topics disable
> -------------------------------------------
>
> Key: FLINK-28672
> URL: https://issues.apache.org/jira/browse/FLINK-28672
> Project: Flink
> Issue Type: Bug
> Components: Table SQL / Runtime
> Affects Versions: 1.13.6
> Reporter: songwenbin
> Priority: Major
>
> 配置了'properties.allow.auto.create.topics' = 'false'，但job执行后都会创建出mocktest27的topic
> CREATE TABLE interval_source7 (
> item STRING,
> val DOUBLE,
> is_energy BIGINT,
> ts BIGINT,
> event_time AS TO_TIMESTAMP_LTZ(ts, 3),
> process_time AS PROCTIME(),
> WATERMARK FOR event_time AS event_time)
> WITH ('connector' = 'kafka', 'topic' = 'daily-consumption', 'properties.bootstrap.servers' = 'broker:9092','properties.group.id' = 'l3_daily-consumption_mocktest','value.format' = 'avro-confluent','value.avro-confluent.schema-registry.url' = 'http://schema-registry:8081','value.fields-include' = 'EXCEPT_KEY', 'scan.startup.mode' = 'earliest-offset');
> CREATE TABLE interval_consumption_sink7 (
> item STRING,
> val DOUBLE,
> ts BIGINT,
> isEnergy BIGINT,
> nodeId INTEGER,
> siteId INTEGER,
> shiftId INTEGER,
> shiftTime BIGINT,
> PRIMARY KEY (item, ts) NOT ENFORCED)
> WITH ('connector' = 'upsert-kafka','topic' = 'mocktest27','properties.allow.auto.create.topics' = 'false' ,'properties.bootstrap.servers' = 'broker:9092', 'key.format' = 'avro-confluent', 'key.avro-confluent.schema-registry.url' = 'http://schema-registry:8081','value.format' = 'avro-confluent',
> 'value.avro-confluent.schema-registry.url' = 'http://schema-registry:8081');
> INSERT INTO interval_consumption_sink7
> SELECT
> item,
> val,
> ts,
> 1 AS is_energy,
> 2,
> 3,
> 4,
> 10000
> FROM interval_source7 ;
--
This message was sent by Atlassian Jira
(v8.20.10#820010)