使用kafka-avro-console-producer而不自动注册架构
我试图使用kafka-avro-console-producer 5.4.0-ccs不自动注册模式。我试着用：
--生产者属性auto.register.schemas=false
--属性auto.register.schemas=false
但它仍然在注册模式。属性似乎正确:https://github.com/confluentinc/schema-registry/blob/a0a04628687a72ac6d01869d881a60fbde4177e7/avro-serializer/src/main/java/io/confluent/kafka/serializers/abstractkafkaavroserdeconfig.java#l54
共有1个答案
CLI的属性似乎是auto.register，而不是auto.register.schemas。我在代码中发现了它，但它可能会在下一个版本中改变，并且没有文档化。
-
下载confluent open source 3.3后在命令行做一个简单的实验： 合流启动-启动所有服务时不会出现任何可见错误：
-
我正在尝试使用kafka-avro-convore-生产者发布一条具有键（带有模式）和值（带有模式）的消息。kafka环境（kafka的conFluent 6.2.0版本、连接、zoomaster、模式注册表）都正确启动，我可以确认我的连接器已安装。问题是当我发送消息时，我的Sink连接器失败并出现我无法诊断的错误。 感谢您的帮助： 我生成一条AVRO消息，如下所示： 并在连接日志中接收以下错误：
-
下午好，我最近才开始与Kafka合作，我有一个关于制作人与模式的问题。 最初，我尝试在C#中构建一个没有模式的简单生产者。到目前为止，这是可行的，代码也在一个简短的版本中给出。 无模式生产者代码： 但是模式会给我带来问题（请参阅下一节）。 假设我给了一个消费者，比如说Python中的消费者，他使用以下方案来接收整数： 我现在想创建一个使用此方案并向Python消费者发送消息的C#生产者。根据该方案
-
我们在当前的基础架构中安装了普通的apache Kafka，并开始记录一些我们想要使用Kafka Connect处理的数据。目前，我们使用Avro作为消息格式，但我们的基础架构中没有模式注册表。将来，我们计划用Confluent替换当前堆栈，并使用Schema Registry和Connect，但在一段时间内，我们只需要为此部署Connect。 是否可以以某种方式配置连接接收器，以便它们使用显式a
-
我尝试将我的自定义类型的< code>ProducerRecord发送到Kafka，但我收到错误消息: 我在schema:GET中设置了schema 回应： 得到 回答 } 这是我的Scala类: Kafka制作人的部分： 我错过了什么？我看到我可以为我的类实现SpecificRecord，但在我阅读的书/教程中，我没有看到这一点。谢谢 编辑：固定类名
-
嘿，我想将ConFluent模式注册表与Avro Serializers一起使用：留档现在基本上是说：不要为多个不同的主题使用相同的模式 谁能解释一下原因吗？我重新搜索了源代码，它基本上将模式存储在Kafka主题中，如下所示（topicname，magicbytes，version- 因此，除了冗余之外，我看不到多次使用模式的问题？