首先得配置GateWay中的config.properties

将Kafka收到的数据传入到redis中

然后再看一下TBox中的properties

将Kafka收到的数据传入到redis中

main方法中

将Kafka收到的数据传入到redis中

 

 Test中的config.properties

将Kafka收到的数据传入到redis中

将Kafka收到的数据传入到redis中

 

将Kafka收到的数据传入到redis中

 

 Test中

将Kafka收到的数据传入到redis中

 

将Kafka收到的数据传入到redis中

 

将Kafka收到的数据传入到redis中

 

先启动网管(GateWay),再启动终端(TBox),然后再运行KafkaTest

将Kafka收到的数据传入到redis中

启动TBox

 将Kafka收到的数据传入到redis中

在启动Test

将Kafka收到的数据传入到redis中

可以看到 接收到数据了 

然后 key是sdf

再到你的xshell中启动 zookeeper,kafka,redis 

然后进入到redis的bin目录下

执行

将Kafka收到的数据传入到redis中

 

 到此 配置完毕

 

相关文章: