我试着给Kafka发送一些自定义头部的消息，但是我找不到方法。根据documatation的说法，POST /topics/(string: topic_name)应用编程接口无法将自定义报头附加到消息。有谁知道通过confluent Kafka REST API发送带有自定义头部的Kafka消息的<
浏览 10提问于2019-03-07得票数 4
回答已采纳
1回答
我已经创建了一个接收器连接器来开始使用死信队列。:355) at io.confluent.kafka.schemaregistry.client.rest.RestService.lookUpSubjectVersion(RestService.j
浏览 10提问于2022-10-25得票数 0
我在我的笔记本电脑上旋转了一个Kafka in Docker (带有docker-compose)。现在尝试生成(基于此示例-步骤3- )： --broker-list localhost:9092 --topic simple:218)
at io.confluent.kafka.schemaregistry.client.rest.RestService.regi
浏览 0提问于2018-04-24得票数 2
2回答
我们有一些应用程序希望使用REST API调用与Kafka通信，以消费和生成消息。如果我们不想使用Confluent REST代理，有什么选择呢？
浏览 10提问于2020-01-24得票数 2
我正在使用集群、Schema服务，并试图在Flink作业中处理Debezium消息。作业被配置为使用Table & SQL连接器和Confluent格式。: Unauthorized; error code: 401 at io.confluent.kafka
浏览 3提问于2021-02-08得票数 3
1回答
我正在尝试读取存储在S3中的avro记录，以便使用confluent提供的S3源代码将它们放回卡夫卡主题中。(AvroConverter.java:84) .还有15个原因是: io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException:352) at io.confluent.kafka.schemaregistry.client.
浏览 7提问于2022-07-07得票数 0
回答已采纳
背景:我在生成prod主题时使用了错误的avro模式注册表，因此由于使用错误的模式id.So作为恢复计划的消息，我们希望将prod主题中的消息复制到测试主题中，然后将好消息写入我们面临的具有错误模式id的特定偏移量的hdfs.But，在从prod topic.Is读取时，有一种方法可以忽略这些偏移量。Exception in thread "Stream
浏览 1提问于2018-05-15得票数 1
回答已采纳
在使用来自Kafka主题的消息时，我反复得到下面的异常。谁能解释一下这个异常是什么意思，以及如何避免它？61 at io.confluent.kafka.schemaregistry.
浏览 12提问于2018-01-16得票数 0
回答已采纳
我正在使用带有MSSQL连接器的Kafka Connect，带有CDC启用的数据库和表。在使用REST API创建任务时，我收到以下错误： ERROR Exception thrown while querying for ChangeKey{databaseName=WebAppDb,schemaName=dbo, tableName=Companies} (io.confluent.connect.cdc.mss
浏览 17提问于2019-01-08得票数 1
下载合流开源3.3之后，在命令行进行一个简单的实验：confluent-3.3.0% confluent startis [UP]kafka-rest is [UP]connect is [UP]
向avro控制台生成器发送一条消息，并查看
浏览 0提问于2018-06-28得票数 0
回答已采纳
2回答
我有一个Kafka连接源和接收器连接器，用于将数据放入Kafka中并将其取出来。我正在使用docker-compose运行Kafka和Kafka Connect，它在分布式模式下运行connect。确保在connect启动时它能找到我的插件，但它实际上不会做任何事情，除非我对JSON执行POST操作，包括/connectors中的配置。我有一个包含配置的属性文件，我尝试将它放在/etc下，在那里我找到了与其他已安装插件类似的属性文件
浏览 21提问于2019-02-26得票数 3
回答已采纳
我有一个模式注册表，kafka，一个本地生产者运行的动物园管理员。问题是，当我手动注册模式并关闭生产者的自动注册时，当我试图为主题生成记录时，我会得到以下异常。令人困惑的是，在使用POST手动注册之后，我已经验证了模式是可用的，所以not没有真正的意义。在这方面的任何帮助都是非常感谢的。Caused by: io.confluent.kafka.schemaregistry.client.r
浏览 8提问于2022-02-02得票数 0
我很难通过Rest代理生成卡夫卡主题.为此，我跟踪了文档并创建了API密钥和机密。, "self": "https://pkc-xmzwx.europe-central2.gcp.conf
浏览 5提问于2022-01-11得票数 0
回答已采纳
我想从Kafka主题推送数据到REST端点。(非企业版，不使用confluent kafka托管服务)。我正在考虑使用Confluent的Kafka Connect HTTP接收器，但我意识到它有30天的试用期，之后它需要许可证。是否有其他开源/免费选项可用作Apache Kafka和REST API之间的双向桥梁。
浏览 4提问于2021-07-19得票数 0
我们有一个带有多个avroregistry的KafkaAvroSerde。在某个时候，serde尝试在1 url上注册模式时超时，但是由于它向流应用程序抛出IO异常，流线程关闭了。从kafka流应用程序的角度来看，这种类型违背了在创建avro serdes时支持多个urls的功能，因为DSL堆栈中出现的运行时异常将关闭stream Thread。几个问题：
我们是否需要在应用程序逻辑中执行重试(当您简单地将主题具体化到商店中时，这可能
浏览 0提问于2018-11-02得票数 2
回答已采纳
我用插件registered.Is启动了kubernetis集群中的连接器，可以在没有REST API ie Json值的情况下启动连接器。指定HELM中的值
浏览 0提问于2018-06-01得票数 0
我对kafka是个新手，我对Confluent平台很好奇。在Confluent平台上似乎没有太多的用户故事。Confluent平台和Apache Kafka有什么不同？
浏览 2提问于2016-09-26得票数 49
回答已采纳
我使用的是kafka_2.11.-0.9.0.1。首先，我用以下命令启动了zookeeper & kafka (如所解释的)：然后：bin/kafka-server-start.sh config/server.properties
现在，我正在尝试从REST API (如所解释的
浏览 0提问于2016-04-27得票数 1
使用者无法处理来自连接器的消息，因为它正在以某种方式转换我的JSON消息；RabbitMQ发送{"transaction": "PAYMENT", "amount": "$125.0"}和kafka-connectconfluentinc/kafka-connect-rabbitmq:latest
请按如下方式生成图像：docker build .- ka
浏览 0提问于2020-01-07得票数 1
回答已采纳
我有一个定义如下的消费者。它读取主题外的avro消息，并构造一个聚合数据的状态存储，该数据也是avro类型的。(RestService.java:226) at io.confluent.kafka.schemar
浏览 23提问于2021-02-27得票数 1
回答已采纳
云服务器
ICP备案
云直播
即时通信 IM
实时音视频
腾讯云开发者
