配置一个卡夫卡连接
您可以配置一个Apache卡夫卡连接的API连接管理器。
这允许您连接到卡夫卡主题商店发送的消息的一个或多个出版商和读取一个或多个消费者。在卡夫卡的详细信息,请参阅Apache卡夫卡文档。
配置您的连接
配置一个卡夫卡连接,遵循以下步骤:
去编辑部分。
指定一个的名字你的连接。
从类型下拉菜单,选择卡夫卡。
输入的名称主题你想连接。
指定主机。这是卡夫卡服务器主机名或IP地址。
进入港口听。
指定GroupId消费者团体。这是群消费者的名字,订阅了这个话题。
输入的数量分区存储记录(消息)。
卡夫卡主题分成多个分区,允许大量数据的分布在一个或多个服务器。每个分区都有一个号码等0或5。
启用窥视从一个分区不提交检索记录。
这允许您阅读任何记录,无论其位置分区并没有影响抵消。偏移量,它定义了一个记录的位置,显示该记录已经被消费和未读记录API引擎应该拉下。
指定的消息KeyType下列选项之一:
忽略设置信息零和序列化的值,但不是关键。
没有一个排除从序列化,价值和关键。
整数消息。
字符串消息。
如果您的连接需要身份验证,您有两个选择:验证用户名和密码或通过SSL。如果你选择SSL,填充以下字段:
指定您的证书文件中.pem。
插入你的密码。这是对你的私钥密码。
在私钥你的私钥,指定路径.pem。
指定CA证书在.pem。这是一根CA证书验证代理卡夫卡的证书。
可选地,配置XML和web服务安全性。
可选地,添加对卡夫卡的Avro基于序列化消息定义记录的数据模式的价值。该模式描述字段允许的价值,连同他们的数据类型。Avro模式的详细信息,请参阅Apache Avro文档。
从模式类型下拉菜单,选择Avro并添加一个模式注册网址和一个模式定义一个JSON格式的数据结构。
如果模式注册需要SSL,填写以下字段:
指定模式注册CA。这是目录路径CA证书。
在模式密钥库注册表,指定的路径密钥存储库用于身份验证。
在模式密钥库注册密码输入密钥存储库密码。
配置值序列化模式和关键串行化模式:
没有一个序列化的键或值。
主题序列化的键或值通过使用注册模式为主题。
配置一个卡夫卡连接
你现在可以用你的卡夫卡连接进行测试。关于如何运行卡夫卡主题的详细信息,见“卡夫卡运行信息”章。
Avro模式序列化格式的支持
卡夫卡连接支持以下模式:
数组
布尔
双
枚举
浮动
Int
逻辑:日期、时间(毫秒)、时间(微秒),时间戳(毫秒),时间戳(微秒),本地时间戳(毫秒),本地时间戳(微秒),UUID
长
零
记录
字符串
联盟