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)
