kafkaメッセージをクリックハウスに一括してキューに入れるには

Question

公式ウェブページhttps://clickhouse.yandex/docs/en/table_engines/kafka.htmlの手順に従って、ストリーミングキューkafkaをclickhouseに一括して送信しようとしています。

私はkafka configurationをチェックしましたし、私はこのキューのフィーダーを作成したと私はclickhouse configurationzookeeper'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()の結果は常に偽で、例外はありません。

アイデア？

ありがとう、 種類です。

Answer 1

clickhouseノードのコマンドラインclickhouse-client でクエリを実行できますか？ cliclhouse-client -c "CREATE TABLE IF NOT EXISTS test.clickhouseMd5 (st1 String,st2 String, st3 String) ENGINE = Kafka('node2:2181', 'TestTopic', 'testConsumerGroup', 'JSONEachRow')"

Answer 2

あなたはzookeeperのデフォルトポートであるポート2181を使用します。 あなたが言及したドキュメント（https://clickhouse.yandex/docs/en/table_engines/kafka.html）によれば、第1引数には、ブローカのカンマ区切りリスト（localhost：9092）を指定する必要があります。

古いカフカバージョンでは機能しない可能性があります。たとえば、0.9.0.1となります。このバージョンでは、CREATE TABLEコマンドはOKを返します。しかし、kafkaログには、 'ERROR'のようなエラーがあります。 （kafka.network.Processor）java.lang.ArrayIndexOutOfBoundsException：18 '

最新のKafka 0.11.0.2ではうまく動作します。