0

公式 Web ページの手順に従って、ストリーミング キュー kafka をクリックハウスにバルクしようとしていますが、正常に実行https://clickhouse.yandex/docs/en/table_engines/kafka.htmlされるようにする方法はありません。

kafka configurationこのキューのフィーダーを作成し、 に追加したので、clickhouse configuration確認しましたが問題zookeeper's hostありませんport

たとえば、日食の文は次のとおりです。

System.out.println(ck.connection.createStatement().execute("CREATE TABLE IF NOT EXISTS test.clickhouseMd5 ("st1 String," + "st2 String," + "st3 String) ENGINE = Kafka('node2:2181', 'TestTopic', 'testConsumerGroup', 'JSONEachRow')"));

の結果System.out.println()は常にfalseであり、例外はありません。

何か案は?

よろしくお願いします。

4

2 に答える 2