songwenbin created FLINK-28672: ---------------------------------- Summary: properties.allow.auto.create.topics无效 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
配置了'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)