我想从Kafka主题推送数据到REST端点。(非企业版，不使用confluent kafka托管服务)。我正在考虑使用Confluent的Kafka Connect HTTP接收器，但我意识到它有30天的试用期，之后它需要许可证。是否有其他开源/免费选项可用作Apache Kafka和REST API之间的双向桥梁。
浏览 4提问于2021-07-19得票数 0
cleanup.policy"，"value"：“压缩”}，{ "name"："compression.type"，"value"："gzip“}} Exception :request:无法调用请求，因为io.confluent.kafkarest.resources.v3
浏览 50提问于2021-04-28得票数 0
1回答
我正在尝试读取存储在S3中的avro记录，以便使用confluent提供的S3源代码将它们放回卡夫卡主题中。我已经有了具有正确模式的主题和注册表设置，但是当连接S3源代码试图将我的记录序列化到主题时，我会得到以下错误
org.apache.kafka.common.errors.SerializationException(AvroConverter.java:84) .还有15个原因是: io.confluent.kafka.schemaregist
浏览 7提问于2022-07-07得票数 0
回答已采纳
之后，创建了新的kafka主题： at io.confluent.kafka.schemaregistry.client.rest.RestService.registerSchema(RestService.java:307)
at io.confluent<
浏览 0提问于2018-04-24得票数 2
我正在尝试使用docker设置Kafka rest代理。但是我在配置中提供的主题不是创建。我正在用curl "http://metrics-kafka-rest:38082/topics"接口检查Kafka主题，得到的回应是：["__confluent.support.metrics","_schemas"]
下面是我在dock
浏览 16提问于2019-08-13得票数 5
回答已采纳
6回答
码头工创作卡夫卡主题
、、、、
Problem：无法从坞撰写创建主题。在运行测试系统之前，我需要创建kafka主题。计划使用它作为管道的一部分，因此使用UI不是一个选项。可能的解决方案
创建</e
浏览 3提问于2020-11-16得票数 21
for id 619 at io.confluent.kafka.schemaregistry.client.rest.RestService.httpRequest(RestService.java:355)
at io.confluent</
浏览 58提问于2021-05-03得票数 0
回答已采纳
在我的用例中，我已经创建了JDBC kafka连接器，从oracle表中提取数据并成功地推送到kafka主题，但是当我尝试从这个kafka主题中读取消息时，我得到如下所列的反序列化问题。org.apache.kafka.common.errors.SerializationException: Error deserializing Avro message for id 2 at io.
浏览 20提问于2019-03-23得票数 2
回答已采纳
我很难通过Rest代理生成卡夫卡主题.为此，我跟踪了文档并创建了API密钥和机密。I设法创建主题：
curl -X POST -H "Authorization: Basic <BASE64_ENCODED_AUTH_KEY_SECRET>&quo
浏览 5提问于2022-01-11得票数 0
回答已采纳
1回答
我开发了一个java应用程序，它使用Schema Registry从avro主题读取数据，然后进行简单的转换，并在控制台中打印结果。默认情况下，我对键和值使用GenericAvroSerde类。当我尝试使用call through() -只是为了将数据发布到新的主题-时，我遇到了我正在询问的问题:主题是在没有模式的情况下创建的。怎么会这样？by: io.confluent.kafka.schemaregistry.client.<em
浏览 0提问于2017-10-05得票数 2
添加连接器将产生一个Request timed out on Kafka Connect [2021-07-22 01:27:19,889] INFO ProcessingLogConfig-07-22 01:27:34,926] INFO API server s
浏览 3提问于2021-07-22得票数 0
1回答
我已经创建了一个连接器来处理Avro数据。我能够将数据发布到一个主题中。但我不会将数据输入到输出主题中。我已经检查了连接器和rest代理的日志，没有显示错误。", "batch.ma
浏览 7提问于2022-04-01得票数 0
我对kafka是个新手，我对Confluent平台很好奇。在Confluent平台上似乎没有太多的用户故事。Confluent平台和Apache Kafka有什么不同？
浏览 2提问于2016-09-26得票数 49
回答已采纳
1回答
我已经永久删除了kafka主题的模式，现在我无法从主题中反序列化消息，该怎么办。: Error retrieving Avro schema for id 100869 Caused by: io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException: Schema 100869 not found; error code: 40403 at io.confluent.
浏览 12提问于2022-09-05得票数 -1
cr = consumer.Consume();
console.Write($"key {cr.Message.Key}\r\nvalue {cr.Message.Value}"); 当我正在收听多个主题时，如何获取特定消息的主题？
浏览 42提问于2021-09-03得票数 1
我正在尝试使用一个新特性()来存储同一主题上的两种不同类型的事件。同样，在Kafka Schema注册表上，会创建两个新条目，每个条目对应于该特定主题上托管的每个事件。 at io.confluent.kafka.schemaregistry.client.rest.RestService.lookUpS
浏览 0提问于2018-05-23得票数 1
1回答
我有一个关于使用Kafka以及主题(Kafka broker)和主题(Schema Registry)的不同名称设置流处理器的问题。: Subject not found.; error code: 40401
at io.confluent.kafka.schemaregistry.client.rest.RestService.sendHttpRequest(RestService.java:298) ~[kafka-sc
浏览 44提问于2021-11-15得票数 0
我正在使用KAFKA，但不知道是否可以使用KAFKA REST API接收json消息，并将其针对特定主题存储在Kafka broker中？
浏览 3提问于2016-10-26得票数 0
在使用来自Kafka主题的消息时，我反复得到下面的异常。谁能解释一下这个异常是什么意思，以及如何避免它？61 at io.confluent.kafka.schemaregistry.
浏览 12提问于2018-01-16得票数 0
回答已采纳
1回答
我已经创建了一个接收器连接器来开始使用死信队列。:355) at io.confluent.kafka.schemaregistry.client.rest.RestService.lookUpSubjectVersion(Rest
浏览 10提问于2022-10-25得票数 0
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号