connect - Debezium连接器插入kafka密钥作为avro?
问题描述
我正在寻找一个 debezium mysql 连接器,以将 CDC 记录流式传输到 kafka,其中键为字符串(不是 avro 键),值作为 avro 记录。默认情况下,它将密钥作为 avro 记录。有什么建议么 ?
解决方案
您可以尝试设置key.converter
并org.apache.kafka.connect.storage.StringConverter
保持value.converter
设置为 Avro 之一。
或者您可以使用 JSON 转换器,因为它也可以序列化为文本。
J。
推荐阅读
- nginx - 第三域请求上的 Nginx 和 gunicorn err 403
- android - 想要在 Oreo 中创建通知而不为频道项目提供类别
- ansible - 模板模块中的 Ansible group_vars
- ruby-on-rails - activerecord-postgis-适配器:#
- java - 按顺序合并多个pdf
- c# - C# 启动一些 cmd 命令,但其他不启动
- angular - 角度 http 请求无法正常工作
- android - 我想像在按钮中一样在中心添加图像和文本
- angular - AWS ec2上的角度网站部署问题
- javascript - 如何在Angular 6中动态创建的按钮上绑定点击事件?