Kafka Connect отказывается от Flink SQL ⇐ JAVA

[Anonymous]

Я хочу обрабатывать данные с помощью flink SQL, вот мой код

Код: Выделить всё

CREATE TABLE ohlc_source (
screener STRING,
symbol STRING,
`open` DOUBLE,
`high` DOUBLE,
`low` DOUBLE,
`close` DOUBLE,
`volume` DOUBLE,
`time` STRING,
rowtime AS TO_TIMESTAMP(`time`),
WATERMARK FOR rowtime AS rowtime - INTERVAL '5' SECOND
) WITH (
'connector' = 'kafka',
'topic' = 'ohvcl_data',
'properties.bootstrap.servers' = 'kafka_broker:19092',
'properties.group.id' = 'test_key',
'properties.auto.offset.reset' = 'earliest',
'format' = 'json'
);

CREATE TABLE ohlc_kafka_sink (
screener STRING,
symbol STRING,
window_start TIMESTAMP(3),
`open` DOUBLE,
`high` DOUBLE,
`low` DOUBLE,
`close` DOUBLE,
`volume` DOUBLE
) WITH (
'connector' = 'kafka',
'topic' = 'ohvl_data',
'properties.bootstrap.servers' = 'kafka_broker:19092',
'format' = 'json'
);

Проблема заключается в том, что на этапе INSERT потребитель отказывается подключаться.

Код: Выделить всё

Flink SQL>
java.net.ConnectException: Connection refused

Это мой файл Docker

Код: Выделить всё

FROM flink:2.0.0
USER root
RUN apt-get update -qq &&\
apt-get install -y --no-install-recommends\
wget curl vim &&\
apt-get clean &&\
rm -rf /var/lib/apt/lists/*
# Set working directory
WORKDIR /opt/flink

RUN wget -q https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-kafka/4.0.0-2.0/flink-sql-connector-kafka-4.0.0-2.0.jar \
-P /opt/flink/lib

Я пытался понизить версию Kafka и выбрать другую банку, но, похоже, это не помогло.

Подробнее здесь: https://stackoverflow.com/questions/798 ... -flink-sql