黄页网站推广方案,wordpress建站方法,决定网站打开的速度,学科主题资源网站的建设Kafka入门到实战 Kafka快速开始官网地址Kafka概述Kafka术语Kafka初体验更新计划 Kafka快速开始
官网地址
声明: 由于操作系统, 版本更新等原因, 文章所列内容不一定100%复现, 还要以官方信息为准
https://kafka.apache.org/Kafka概述 Apache Kafka 是一个开源的分布式事件流… Kafka入门到实战 Kafka快速开始官网地址Kafka概述Kafka术语Kafka初体验更新计划 Kafka快速开始
官网地址
声明: 由于操作系统, 版本更新等原因, 文章所列内容不一定100%复现, 还要以官方信息为准
https://kafka.apache.org/Kafka概述 Apache Kafka 是一个开源的分布式事件流平台提供高性能数据管道、流分析、 数据集成和任务关键型应用程序。 Kafka术语
Event 事件具有键、值、时间戳和可选的元数据头Producers 生产者是向 Kafka 发布写入事件的客户端应用程序Consumers 消费者是订阅读取和处理这些事件的客户端应用程序Topics 主题类似于文件系统中的文件夹事件是该文件夹中的文件Partitioned 一个主题分布在位于不同 Kafka 代理上的多个“存储桶”上Replicated 数据具有容错性和高度可用性, 可以有多个备份
Kafka初体验
下载安装部分, 过于简单, 不宜演示, 请参考官网教程 创建一个主题,名称叫做quickstart-events
bin/kafka-topics.sh --create --topic quickstart-events --bootstrap-server localhost:9092查看topic的详细信息
bin/kafka-topics.sh --describe --topic quickstart-events --bootstrap-server localhost:9092将事件写入到kafka bin/kafka-console-producer.sh --topic quickstart-events --bootstrap-server localhost:9092
hello
kafka读取事件
bin/kafka-console-consumer.sh --topic quickstart-events --from-beginning --bootstrap-server localhost:9092Kafka Connect 将数据导入/导出为事件流 echo plugin.pathlibs/connect-file-3.7.0.jar config/connect-standalone.propertiesecho -e foo\nbar test.txtbin/connect-standalone.sh config/connect-standalone.properties config/connect-file-source.properties config/connect-file-sink.properties执行完会有一个test.sink.txt文件, 也可以通过下边的命令查看数据
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic connect-test --from-beginning
echo Another line test.txt使用 KAFKA STREAMS 处理事件 先贴出来代码, 等后边实战会贴出来运行效果
KStreamString, String textLines builder.stream(quickstart-events);KTableString, Long wordCounts textLines.flatMapValues(line - Arrays.asList(line.toLowerCase().split( ))).groupBy((keyIgnored, word) - word).count();wordCounts.toStream().to(output-topic, Produced.with(Serdes.String(), Serdes.Long()));更新计划
欲知后事如何, 请听下回分解
