MQTT Kafka源连接器：有趣的字节字符

作者: 土豆
发布时间: 2024-04-11 08:17:37 (8天前)
转自：

2 条回复

0#
回复此人
绵绵 | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <P> 作为演示的一部分，您将启动Schema Registry </p> <BLOCKQUOTE> <P> 启动Kafka Connect和依赖项（Kafka，Zookeeper，Schema Registry）： </p> <P> <code> confluent start connect </code> </p> </BLOCKQUOTE> <P> 如果查看前5个字节，您将看到它们以0开头，然后是另外4个字节表示整数。 </p> <P> 见 <a href="https://docs.confluent.io/current/schema-registry/docs/serializer-formatter.html#wire-format" rel="nofollow noreferrer"> 架构注册表线格式 </A> 并尝试做一个 <code> curl localhost:8081/subjects </code> 看它是否列出了您的主题名称 <code> mqtt-key </code> 和 <code> mqtt-value </code> 。 </p> <P> 如果您不想要Avro，则需要配置和编辑Kafka Connect属性文件以使用不同的转换器，而不是使用 <code> confluent start </code> 让Kafka和Zookeeper运行 </p> <P> 或者，如果您希望Python反序列化Avro，您可以参考Github上的confluent-kafka-python repo </p> </DIV>

编辑

登录后才能参与评论