0

私はカフカからクリックハウスにいくつかのリアルタイムメトリックを入れようとしていました.私のクエリは以下のようになります

CREATE TABLE queue2 (timestamp String, namespace String, data Float, unit String, plugin_running_on String, version UInt64, last_advertised_time String) ENGINE = Kafka('10.224.54.99:9092', 'outtopic1', 'group2', 'JSONEachRow');

カフカから約 150 行のメトリクスを取得しているため、突然停止し、

156 rows in set. Elapsed: 11.245 sec.

しかし、クリックハウスにプッシュする必要があるカフカにはデータがまだ残っています...何が問題なのでしょうか? 誰か助けてくれませんか

4

1 に答える 1