From f41ae664013bef7770c4d07d2aef418c6227151d Mon Sep 17 00:00:00 2001
From: Shiny <shiny.zhu@neo4j.com>
Date: Thu, 30 Dec 2021 18:05:02 +0800
Subject: [PATCH] Update kafka-neo4j.md

---
 .../kafka-neo4j.md"                           | 46 +++++++++++++++++++
 1 file changed, 46 insertions(+)

diff --git "a/data/2.Neo4j \344\270\255\351\230\266/4.\345\272\224\347\224\250\345\274\200\345\217\221\345\222\214\351\233\206\346\210\220/4.Apache Kafka\350\277\236\346\216\245\345\231\250/kafka-neo4j.md" "b/data/2.Neo4j \344\270\255\351\230\266/4.\345\272\224\347\224\250\345\274\200\345\217\221\345\222\214\351\233\206\346\210\220/4.Apache Kafka\350\277\236\346\216\245\345\231\250/kafka-neo4j.md"
index a512460..a57edd5 100644
--- "a/data/2.Neo4j \344\270\255\351\230\266/4.\345\272\224\347\224\250\345\274\200\345\217\221\345\222\214\351\233\206\346\210\220/4.Apache Kafka\350\277\236\346\216\245\345\231\250/kafka-neo4j.md"	
+++ "b/data/2.Neo4j \344\270\255\351\230\266/4.\345\272\224\347\224\250\345\274\200\345\217\221\345\222\214\351\233\206\346\210\220/4.Apache Kafka\350\277\236\346\216\245\345\231\250/kafka-neo4j.md"	
@@ -1,2 +1,48 @@
 # Neo4j的Apache kafka连接器
 
+Kafka Connect 是 Apache Kafka 的开源组件，是一个框架，用于将 Kafka 与外部系统（例如数据库、键值存储、搜索索引和文件系统）连接起来。
+
+Neo4j Streams 项目提供了一个 Kafka Connect Neo4j 连接器，它可以安装到 Confluent 平台中，从而实现：
+
+- 通过模板化的 Cypher 查询将来自 Kafka 主题的数据直接摄取到 Neo4j 中；
+- 流式处理 Neo4j 查询。
+
+Neo4j Streams 将 Neo4j 与 Apache Kafka 事件流集成在一起，用作数据源，例如更改数据 (CDC) 或接收器以将任何类型的 Kafka 事件摄取到您的图形中。
+
+Kafka Connect Neo4j Sink 插件将与 Confluent Cloud 以及大多数形式的 Apache Kafka 一起使用，包括使用单独的 Connect 框架和基础设施在本地运行。建议需要数据接收器功能的人使用此方法。
+
+企业用户可以在他们现有的支持协议下使用 Neo4j Streams。Neo4j 社区用户也可以在社区支持下使用 Neo4j Streams。
+
+- [Kafka Connect：Neo4j 源插件](https://neo4j.com/docs/labs/neo4j-streams/current/#_kafka_connect)（[Confluent Hub](https://www.confluent.io/connector/kafka-connect-neo4j-sink/)）
+- [Neo4j 插件：更改数据源](https://neo4j.com/docs/labs/neo4j-streams/current/#_neo4j_streams_producer)
+- [Neo4j 插件：接收器](https://neo4j.com/docs/labs/neo4j-streams/current/#_neo4j_streams_consumer)
+- [Neo4j 插件：程序](https://neo4j.com/docs/labs/neo4j-streams/current/#_procedures)
+- [Docker Compose 设置](https://neo4j.com/docs/labs/neo4j-streams/current/#docker)
+
+![](https://neo4j.com/labs/kafka/_images/kafka-source-flow.png)
+
+问题：
+
+下列描述中哪一个是不正确的？
+
+## 答案
+
+Kafka连接器只能与Confluent平台一起使用
+
+## 选项
+
+### A
+
+不需要同时配置Neo4j插件和Kafka Connect工作线程
+
+### B
+
+作为**Neo4j 插件**，neo4j-streams 运行在数据库内部，可以消费和生成消息到 Kafka。
+
+### C
+
+一个挑战是将Kafka中的消息转换成图数据模型，然后加载到Neo4j中
+
+### D
+
+Kafka连接器只能与Confluent平台一起使用
-- 
GitLab