将 Kafka 流输入打印到控制台?示例数据问题法典
我一直在查看很多Kafka文档,了解我正在开发的Java应用程序。我已经尝试过进入Java 8中引入的lambda语法,但我在这方面有点粗略,并且不太相信它应该是我迄今为止使用的。
我有一个Kafka / Zookeeper服务运行没有任何麻烦,我想做的是编写一个小的示例程序,该程序基于输入将其写出来,但不进行字数统计,因为已经有很多例子了。
至于示例数据,我将得到以下结构的字符串:
示例数据
This a sample string containing some keywords such as GPS, GEO and maybe a little bit of ACC.
问题
我希望能够提取3个字母的关键字,并用.如何获取包含输入的字符串变量?我知道如何应用正则表达式,甚至只是搜索字符串来获取关键字。System.out.println
法典
public static void main(String[] args) {
Properties props = new Properties();
props.put(StreamsConfig.APPLICATION_ID_CONFIG, "app_id");
props.put(StreamsConfig.BOOTSTRAP_SERVERS_CONFIG, "0:0:0:0:0:0:0:1:9092");
props.put(StreamsConfig.ZOOKEEPER_CONNECT_CONFIG, "0:0:0:0:0:0:0:1:2181");
props.put(StreamsConfig.KEY_SERDE_CLASS_CONFIG, Serdes.String().getClass().getName());
props.put(StreamsConfig.VALUE_SERDE_CLASS_CONFIG, Serdes.String().getClass().getName());
final Serde<String> stringSerde = Serdes.String();
KStreamBuilder builder = new KStreamBuilder();
KStream<String, String> source = builder.stream(stringSerde, stringSerde, "in-stream");
KafkaStreams streams = new KafkaStreams(builder, props);
streams.start();
//How do I assign the input from in-stream to the following variable?
String variable = ?
}
我有动物园管理员,kafka,生产者和消费者运行都连接到同一个主题,所以我希望基本上看到相同的出现在所有实例(生产者,消费者和流)上。String