Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
CSDN 技术社区
skill_tree_neo4j
提交
f41ae664
S
skill_tree_neo4j
项目概览
CSDN 技术社区
/
skill_tree_neo4j
通知
19
Star
4
Fork
3
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
0
列表
看板
标记
里程碑
合并请求
0
DevOps
流水线
流水线任务
计划
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
S
skill_tree_neo4j
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
0
Issue
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
DevOps
DevOps
流水线
流水线任务
计划
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
流水线任务
提交
Issue看板
提交
f41ae664
编写于
12月 30, 2021
作者:
Neo4j 开发者
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
Update kafka-neo4j.md
上级
e3bbf0de
变更
1
隐藏空白更改
内联
并排
Showing
1 changed file
with
46 addition
and
0 deletion
+46
-0
data/2.Neo4j 中阶/4.应用开发和集成/4.Apache Kafka连接器/kafka-neo4j.md
data/2.Neo4j 中阶/4.应用开发和集成/4.Apache Kafka连接器/kafka-neo4j.md
+46
-0
未找到文件。
data/2.Neo4j 中阶/4.应用开发和集成/4.Apache Kafka连接器/kafka-neo4j.md
浏览文件 @
f41ae664
# 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平台一起使用
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录