我正在尝试使用下面的命令创建主题 kafka-topics --create --bootstrap-server confluent-platform-cp-kafka:9092 --replication-factor1 --partitions 1 --topic push.rdes.portfolios --config confluent.value.schema.validation=true 然而，我得到了下面的错误(kafka.admin.TopicCo
浏览 13提问于2021-02-03得票数 3
2回答
我使用的是Kafka & Schema-registry。在生产者端使用confluent的KafkaAvroSerializer定义了一个模式。一切都很好。想知道是否有更好的方法来强制执行更强的模式验证，从而使主题不会被坏数据污染？
浏览 2提问于2019-09-05得票数 4
在控制中心UI中，我能够为主题创建一个主题并设置一个模式。但是，架构验证没有启用，而且仍然可以将任意文本写入主题。通过将这些选项添加到我的helm值中，我试图以的形式启用模式验证： configurationOverrides:
"confluent.schema.registry.url": http://data-cp-schema-registry:8081
浏览 11提问于2022-05-24得票数 0
回答已采纳
3回答
在Kafka启动时，多条消息记录到kafka/logs/kafkaServer.out并包含：
( org.apache.kafka.common.errors.TimeoutException：)无法创建org.apache.kafka.common.errors.InvalidReplicationFactorException08
浏览 5提问于2020-12-08得票数 5
回答已采纳
1回答
我与Avro一起使用合流模式注册表，我想在一个Kafka主题中使用多个模式。
默认主题命名策略TopicNameStrategy不允许这样做，因为它将模式主题名称耦合到主题名称。因此，您现在可以选择使用confluent.key.subject.name.strategy和confluent.value.subject.name.strategy将模式主题键和值配置为默认的命名策略
浏览 11提问于2020-10-31得票数 2
回答已采纳
由于某些原因，_confluent_telemetry_metrics会自动启用。即使使用telemetry.enabled=false关闭了Confluent遥测报表程序，也会发生这种情况。这是我笔记本电脑上的Confluent Operator和Kubernetes (Confluent Platform v6.0)。- KafkaExporterConfig values: topic.name = _con
浏览 46提问于2020-12-02得票数 1
之后，创建了新的kafka主题：(尚未在架构注册表中创建架构)。: Unexpected character ('<' (code 60)): expected a valid value (number, String, array, object, '<em
浏览 0提问于2018-04-24得票数 2
我正在尝试将Confluent Schema Registry部署到我们内部的AWS基础架构(ECS)中，这样它就可以作为REST API使用。完整的图像已经可以从Confluent获得，网址是： https://hub.docker.com/r/confluentinc/cp-schema-registry 我已经创建了一个DockerfileSCHEMA_REGISTRY_HOST_NAME="0.0.0.0"
ENV SCHEMA
浏览 46提问于2019-05-25得票数 2
阅读卡夫卡主题： "schema":{ "fields":[ "type":"int32"field":"prop" { "optional&q
浏览 2提问于2020-05-05得票数 0
1回答
我的系统将有多个客户，主题将是客户，命名与特殊代码。 在哪里可以实现Kafka主题授权并从代码中设置它们？ 例如，从AdminClient创建一个主题是可能的，只需一些设置？
浏览 51提问于2021-08-05得票数 0
1回答
我使用Content5.4.1来使用value_delimiter创建流属性。/current/cli/index.html
Starting zookeeper52103 Jps1741[Dev root @ my
浏览 2提问于2020-03-11得票数 0
我让Kafka运行在合流云上，在那里我可以使用Node.js客户机生成数据，数据以字符串的形式发送，我可以在合流云中得到以下字段。
PUT /locations "mappings": {
"propertie
浏览 2提问于2020-10-25得票数 0
由于看起来是身份验证问题，我无法在Schema注册表中注册Avro Schema。
我已经通过UI为主题设置了一个Cloud集群并定义了一个avro模式。我还通过UI设置了Api键。我已经验证了可以使用下面的curl-curl -u keyid:secretkey https://schema-reg-url/subjects查询subjects。所以我使用的API键应该很好。我也尝试过用正确的属性设置RestService (如下所示)，但我仍然无
浏览 1提问于2019-07-31得票数 1
回答已采纳
1回答
我有使用Protobuf生成的主题事件。我可以使用Parquet格式的S3接收器连接器将我的主题事件成功地沉入到S3存储桶中。"value.converter.basic.auth.user.info": "MY_SR_API_KEY:MY_SR_API_SECRET",
"store.kafka.keys": trueProtobuf把我的键和值以my-bucket-123 (parquet格式)放回一个Kafka主题</e
浏览 2提问于2021-07-30得票数 0
我使用使用kafka_2.11-0.10.1.1的confluent-kafka-0.9.2 (主分支) python绑定来运行librdkafka-0.9.2。我运行confluent producer示例如下：$ python producer.py localhost:9095 confluent备注
该主题已在动物园管理员上成功创建。, 'def
浏览 3提问于2017-01-27得票数 0
回答已采纳
1回答
我试图以json格式从一些kakfa消息中创建一个流，例如： "name": "xxxxxxx",PS。如何将主题“绑定”到注册表架构？
谢谢。
浏览 2提问于2020-07-14得票数 0
回答已采纳
当试图将JDBC连接器连接到Kafka中的某个主题时，我收到了此错误，但我无法修复它。可以使用架构成功地序列化和反序列化数据，并在将其发送到主题之前对其进行验证。此外，主题上的基本使用者可以接收发送到主题中的消息，但JDBC连接器不能将消息中的值映射到表中。我尝试过auto.create = true和auto.evolve = true，但没有运气。值得注意的是，对于不同的主题，
浏览 16提问于2022-03-17得票数 0
1回答
我开发了一个java应用程序，它使用Schema Registry从avro主题读取数据，然后进行简单的转换，并在控制台中打印结果。默认情况下，我对键和值使用GenericAvroSerde类。当我尝试使用call through() -只是为了将数据发布到新的主题-时，我遇到了我正在询问的问题:主题是在没有模式的情况下创建的。怎么会这样？有趣的事实是，数据正在被写入，但它是: a)是二进制格式，因此简单的消费者无法读取它b)它没有模
浏览 0提问于2017-10-05得票数 2
2回答
我正在构建一个Spring Boot 2.4.4应用程序，使用模式验证向Kafka (Confluent Platform)生成消息。该模式是在该主题的模式注册表中设置的，我已经使用Maven Avro插件从相关的AVSC文件创建了POJO (LoanInitiate)。使用以下内容发送时，没有问题： import org.springframework.messaging.Message;
import org.springframework.mes
浏览 293提问于2021-04-23得票数 1
1回答
在我的公司，我们广泛地使用Kafka，但是我们一直使用关系数据库来存储几个中间转换和聚合的结果，因为容错原因。现在，我们正在探索卡夫卡流作为一种更自然的方式来做到这一点。我以为卡夫卡创造了内部主题来实现这一点，但我没有看到任何内部议题被创造出来。似乎证实了这一观点。但后来我发现了这个，它似乎暗示了卡夫卡使用了一个单独的数据存储( datastore，RocksDB )以及一个变化的主题。
如果按照官方页面的建议，状态存储的<e
浏览 0提问于2018-05-09得票数 3
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
