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/07/25 10:56:00 UTC
[jira] [Created] (FLINK-28672) properties.allow.auto.create.topics无效
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)