(一)kafka-jstormクラスタリアルタイムログ分析の-----kafkaリアルタイムログ処理-----続き

上記(一)kafka-jstormクラスタのリアルタイムログ分析の------kafkaリアルタイムログ処理-ログがkafkaクラスタにどのように書き込まれるかについて述べたが、効果を見てみる.
zookeeperクラスタ、kafkaクラスタが起動した後、kafka-web-console(https://github.com/claudemamo/kafka-web-console)クラスタの動作状態を観察する.
kafka-web-consoleを配置し、zookeeperクラスタ、3つのzookeeperの状態を観察する、下図に示すように、Status状態は接続されている.
kafkaクラスタの状況を観察すると、以下の図のように、2つのkafkaはzookeeperクラスタに登録されている.
kafak topicを観察すると、次の図があります.下図はまだメッセージログを起動していません.これは前回残った状態です.
では、ログ・メッセージ・プロバイダ、KafkaAppenderTestテスト・ポータルを起動し、junit testpublic void test_を実行します.log_producer()メソッド
次にpublic void test_を実行しますcomsumer()メソッド.
コンソール情報は以下の通りである:ログメッセージproducer、kafkaクラスタにログ情報を生産した.

while(true){
			LOG.info("test_log_producer : "  + RandomStringUtils.random(3, "hello doctro,how are you,and you"));
		}

kafkaメッセージ消費者が受信したログ情報を見てみましょう.

			while(it.hasNext())
			System.out.println(new String("test_comsumer: " + new String(it.next().message())));

証明ログメッセージはkafakクラスタに書き込まれ、消費者はkafkaクラスタからこれらのリアルタイムログ情報を消費することもできる.
次回は、統合jstormの東を貼り付けます.