如何使用confluent rest api创建kafka主题
要使用Confluent REST API创建Kafka主题，可以按照以下步骤进行：
- 确保你已经安装并配置了Kafka和Confluent REST Proxy。可以参考Confluent官方文档进行安装和配置。
- 使用HTTP POST请求来创建Kafka主题，发送请求到Confluent REST Proxy的主题管理API。具体的API端点为：
- 使用HTTP POST请求来创建Kafka主题，发送请求到Confluent REST Proxy的主题管理API。具体的API端点为：
- 其中，
<topic_name>是你想要创建的主题的名称。 - 在请求的body中，传递主题的配置参数。可以使用JSON格式的数据来设置配置参数。常用的配置参数包括：
partitions：指定主题的分区数量。replication_factor：指定主题的副本数量。- 其他可选参数，如
cleanup.policy、retention.ms等。 - 一个示例请求的body如下所示：
- 一个示例请求的body如下所示：
- 发送请求并等待响应。如果一切正常，你将收到一个HTTP 200 OK的响应，表示主题创建成功。
在使用Confluent REST API创建Kafka主题时，建议使用腾讯云的相关产品和服务。腾讯云提供了一套丰富的云原生解决方案，包括云服务器CVM、云数据库TDSQL、云存储COS等产品，可满足云计算领域的各种需求。具体地，你可以考虑使用腾讯云的Apache Kafka for Tencent Cloud（腾讯云Kafka）产品来进行消息队列的管理和处理。腾讯云Kafka是一种高吞吐量、低延迟的分布式消息系统，适用于大规模实时数据流的处理和分析。你可以在腾讯云官网的腾讯云Kafka产品介绍页面（https://cloud.tencent.com/product/ckafka）了解更多信息和产品详情。
相关·内容
1回答
我试图在Kubernetes中部署Schema。然而，当我尝试用部署文件创建一个pod时，它总是以以下错误重新启动：
io.confluent.kafka.schemaregistry.exceptions.SchemaRegistryInitializationException: Error initializing kafka store while initializing schema registry
at io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry.init(KafkaSchemaRe
浏览 37提问于2022-06-30得票数 0
我正在尝试启动kafka模式注册表，但收到以下错误:无法将Noop记录写入kafka存储。堆栈跟踪如下所示。我检查了和动物园管理员，卡夫卡经纪人的联系-一切都很好。我可以给卡夫卡发消息。我试图删除_schema主题，甚至重装kafka，但这个问题仍然存在。昨天一切正常，但是今天，在重启我的流浪汉机器后，这个问题出现了。有什么我能做的吗？谢谢
[2015-11-19 19:12:25,904] INFO SchemaRegistryConfig values:
master.eligibility = true
port = 8081
kafkastore.timeout.ms = 500
k
浏览 9提问于2015-11-20得票数 7
1回答
我已经永久删除了kafka主题的模式，现在我无法从主题中反序列化消息，该怎么办。
堆栈跟踪：
Internal Server Error
A 500 error has occurred: Request processing failed; nested exception is org.apache.kafka.common.errors.SerializationException: Error retrieving Avro schema for id 100869
Stack trace
org.apache.kafka.common.errors.SerializationExce
浏览 12提问于2022-09-05得票数 -1
1回答
我正在尝试读取存储在S3中的avro记录，以便使用confluent提供的S3源代码将它们放回卡夫卡主题中。我已经有了具有正确模式的主题和注册表设置，但是当连接S3源代码试图将我的记录序列化到主题时，我会得到以下错误
org.apache.kafka.common.errors.SerializationException:错误注册Avro模式引起的：.在io.confluent.kafka.serializers.AbstractKafkaAvroSerializer.serializeImpl(AbstractKafkaAvroSerializer.java:121) at io.conf
浏览 7提问于2022-07-07得票数 0
回答已采纳
1回答
我已经创建了一个连接器来处理Avro数据。我能够将数据发布到一个主题中。但我不会将数据输入到输出主题中。我已经检查了连接器和rest代理的日志，没有显示错误。
{
"name": "sink-elastic_avro_2_topic",
"config": {
"connector.class": "io.confluent.connect.http.HttpSinkConnector",
"headers": "Content-Type:ap
浏览 7提问于2022-04-01得票数 0
1回答
我有一个关于使用Kafka以及主题(Kafka broker)和主题(Schema Registry)的不同名称设置流处理器的问题。 spring:
cloud:
schema-registry-client:
endpoint: http://localhost:8081
cached: true
stream:
function:
definition: process
default:
consumer:
use-native-decoding: true
浏览 44提问于2021-11-15得票数 0
我正在我们的Kubernetes集群上运行一个ksqlDB服务器，我想添加一个连接器。
添加连接器将产生一个Request timed out on Kafka Connect
因此，他建议修改包含在他的坞-撰写示例中的KAFKA_OFFSET_REPLICATION_FACTOR。
但不幸的是，在我们的Test环境中，我无法很容易地访问现有的Kafka集群(我们在那里有管理员)，所以我认为最快的方法是更改：
KSQL_CONNECT_CONFIG_STORAGE_TOPIC -更改为不同的主题名称
KSQL_CONNECT_OFFSET_STORAGE_TOPIC
KSQL_C
浏览 3提问于2021-07-22得票数 0
使用以下配置创建接收器连接器时
connector.class=io.confluent.connect.s3.S3SinkConnector
s3.region=us-west-2
topics.dir=topics
flush.size=3
schema.compatibility=NONE
topics=my_topic
tasks.max=1
s3.part.size=5242880
format.class=io.confluent.connect.s3.format.avro.AvroFormat
# added after comment
key.converter=io.co
浏览 5提问于2018-07-20得票数 0
回答已采纳
我正在尝试使用docker设置Kafka rest代理。但是我在配置中提供的主题不是创建。
我正在用curl "http://metrics-kafka-rest:38082/topics"接口检查Kafka主题，得到的回应是：["__confluent.support.metrics","_schemas"]
下面是我在docker-compose中使用的配置：
image: confluentinc/cp-zookeeper:5.3.0
container_name: 'metrics-zookeeper'
浏览 16提问于2019-08-13得票数 5
回答已采纳
对于Kafka主题，我可以使用confluent consumer api订阅和接收消息。对于Kafka Ktables，我可以使用REST API和http客户端进行订阅。所以我的问题是，也许可以不通过rest api而是confluent consumer api来订阅Kafka表？
以下是我订阅topic的方式：
using (var consumer = new ConsumerBuilder<Ignore, string>(conf).Build())
{
try
{
con
浏览 0提问于2019-07-31得票数 0
1回答
我正在尝试使用Replicator as it is specified in the tutorial将模式注册表从本地集群迁移到Confluent Cloud。它成功地复制了所有的主题，除了几个，我不知道为什么…它会显示以下错误： ERROR Failed to translate schema registry record (io.confluent.connect.replicator.schemas.SchemaTranslator:188)
io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientEx
浏览 14提问于2020-10-06得票数 0
我在一个项目中使用kafka，具体来说，我使用的是合流云的托管kafka。我需要更新我的代理配置(特别是字段offsets.retention.minutes)，但我在的时候有点不知所措--应该怎么做。他们的在线控制台没有提供任何方法让我看到，我已经尝试使用他们专有的“confluent”CLI，声称能够完成我想要的事情(通过：)，但是我必须向该工具传递一个URL才能执行特定的命令(其他命令运行良好，但代理命令不起作用)，当我传递汇流云UI中提供的默认REST URL时，该工具失败了。
但是，为了完整起见，我尝试运行的命令有以下形式：
confluent kafka broker update
浏览 9提问于2022-11-30得票数 0
回答已采纳
我有一个接收器连接器，配置如下
{
"name": "sink-test-mariadb-MY_TOPIC",
"config": {
"connector.class":"io.confluent.connect.jdbc.JdbcSinkConnector",
"tasks.max":"10",
"topics":"MY_TOPIC",
浏览 0提问于2019-01-17得票数 4
6回答
码头工创作卡夫卡主题
、、、、
Problem：无法从坞撰写创建主题。在运行测试系统之前，我需要创建kafka主题。计划使用它作为管道的一部分，因此使用UI不是一个选项。
注意:卡夫卡需要15秒才能准备好，所以我需要在添加主题之前先睡上15秒。
可能的解决方案
创建一个包含命令等待15秒的shell.sh文件，然后添加一系列主题
为它创建一个dockerfile
在启动所测试的系统之前，将该坞映像包括在docker-compose.yml中。
电流
创建动物园管理员-好的
创建kafka1 - OK
rest-代理-好的
创建主题<- PROBLEM
创建SUT - OK
浏览 3提问于2020-11-16得票数 21
有时我们面临以下问题：
Caused by: org.apache.kafka.common.errors.SerializationException: Error retrieving Avro unknown schema for id 16 Caused by: io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException: Schema 16 not found io.confluent.rest.exceptions.RestNotFoundException: Schema 16 not
浏览 5提问于2022-07-25得票数 0
我使用如下所示的curl命令将两个模式添加到Schema注册表中(以及它们的共同响应)
curl -X POST -H "Content-Type: application/vnd.schemaregistry.v1+json" \
--data '{"schema": "{\"namespace\":\"org.example\",\"type\":\"record\",\"name\":\"personKey\",\"version\
浏览 3提问于2021-03-19得票数 0
我已经检查了两个类似的问题，但它没有帮助。
node 1 [/appl/node1/confluent-4.0.0] ./bin/confluent status elasticsearch-sink
{"name":"elasticsearch-sink","connector":{"state":"RUNNING","worker_id":"10.192.226.24:8083"},"tasks":[{"state":"FAILED&#
浏览 2提问于2018-04-17得票数 0
1回答
在将清理策略设置为模式注册表后，我得到了一个模式未找到异常。
错误是(stack_trace)：
org.apache.kafka.common.errors.SerializationException: Error retrieving Avro schema for id 425
Caused by: io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException: Schema not found; error code: 40403
at io.confluent.kafka.schemareg
浏览 4提问于2022-04-01得票数 0
1回答
我最近已经将Confluent升级到4.1，但是模式注册似乎有一些问题。在confluent start模式注册中心(因此也是ksql-server)上，无法启动。
下面是模式注册日志中的错误：
[2018-04-20 11:27:38,426] ERROR Error starting the schema registry (io.confluent.kafka.schemaregistry.rest.SchemaRegistryRestApplication:65)
io.confluent.kafka.schemaregistry.exceptions.SchemaRegistryIn
浏览 2提问于2018-04-20得票数 0
回答已采纳
1回答
我遵循这里的合流示例，
运行docker-compose up -d之后，当我关闭服务器时，所有的主题、流、表都会消失。
有办法坚持下去吗？我正在寻找文件位置的所有主题，流和表存储在，以便我可以做一个绑定-挂载到我的主机pc。这样，它就能持续下去。
下面是docker-compose.yml文件
---
version: '2'
services:
zookeeper:
image: confluentinc/cp-zookeeper:7.2.1
hostname: zookeeper
container_name: zookeeper
po
浏览 12提问于2022-09-10得票数 0
回答已采纳
我正在尝试为AWS MSK集群使用kafka rest代理。
MSK加密详细信息：
集群中的
TLS加密:启用
客户与经纪人之间的
TLS加密:启用
明文:未启用
我在MSK上创建了主题"TestTopic“，然后在与MSK相同的VPC中创建了另一个作为Rest代理的EC2实例。以下是kafka- Here .rest.properties的详细信息：
zookeeper.connect=z-3.msk.xxxx.xx.xxxxxx-1.amazonaws.com:2181,z-1.msk.xxxx.xx.xxxxxx-1.amazonaws.com:2181
bootstrap.se
浏览 4提问于2021-06-07得票数 0
回答已采纳
1回答
我已经创建了一个接收器连接器来开始使用死信队列。但是，它显示模式没有发现异常，如下所示：
Caused by: org.apache.kafka.common.errors.SerializationException: Error retrieving Avro key schema version for id 103925
Caused by: io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException: Schema not found; error code: 40403
at io
浏览 10提问于2022-10-25得票数 0
我们有一个带有多个avroregistry的KafkaAvroSerde。在某个时候，serde尝试在1 url上注册模式时超时，但是由于它向流应用程序抛出IO异常，流线程关闭了。从kafka流应用程序的角度来看，这种类型违背了在创建avro serdes时支持多个urls的功能，因为DSL堆栈中出现的运行时异常将关闭stream Thread。几个问题：
有什么好办法处理这件事吗？
我们是否需要在应用程序逻辑中执行重试(当您简单地将主题具体化到商店中时，这可能是很棘手的)？
否则是否有一个avroserde包装器
可以用实际配置的avroRegistry urls重试吗？
当
浏览 0提问于2018-11-02得票数 2
回答已采纳
我很好奇Confluent的Kafka REST代理和生产者/消费者在kafka官方客户库中实现的优缺点。我知道Confluent的Kafka REST代理用于管理任务和不受kafka客户端支持的语言。
那么，卡夫卡客户的优势是什么呢？
浏览 1提问于2018-06-29得票数 4
回答已采纳
我想得到一个主题中的分区数，但是API充其量是难以理解的。
我发现了以下内容，但是主题信息不包含分区的数量。
import confluent_kafka
from confluent_kafka.admin import AdminClient, ConfigResource
kafkaServers = ["***","****"]
bootstrapServers = ",".join(kafkaServers)
adminClient = AdminClient({
'bootstrap.servers':
浏览 9提问于2022-05-12得票数 0
回答已采纳
我有一个现有的kafka经纪人:9092。该代理运行的是Apache Kafka版本2.2.0。我想使用ksqlDB对来自kafka broker上的主题的数据进行一些流处理。因此，根据https://docs.confluent.io/platform/current/installation/versions-interoperability.html的兼容性表，我使用的是Confluent Platform V5.2中的ksqlDB。 我在ksql/ksql-server.properties中设置了bootstrap.servers=<myurl>:9092。 但是，当我
浏览 43提问于2021-01-26得票数 0
回答已采纳
我正在使用集群、Schema服务，并试图在Flink作业中处理Debezium消息。作业被配置为使用Table & SQL连接器和Confluent格式。但是，作业无法连接到架构注册表并引发401错误。
表连接器配置
tEnv.executeSql("CREATE TABLE flink_test_1 (\n" +
" ORDER_ID STRING,\n" +
" ORDER_TYPE STRING,\n" +
" USER_ID STRING,\n" +
浏览 3提问于2021-02-08得票数 3
我使用的是databricks运行时10.0和Spark3.2.0和Scala2.12。我还依赖于io.confluent:kafka-schema-registry-client:6.2.0，，使用CachedSchemaRegistryClient在模式注册表中注册模式，如下所示：
import org.apache.avro.Schema
import io.confluent.kafka.schemaregistry.avro.AvroSchema
@transient lazy val reg = new CachedSchemaRegistryClient(schemaRegis
浏览 5提问于2022-03-03得票数 1
回答已采纳
我有一个现有的ksqldb服务器，我想将它从以连接作为分离节点的v0.6.0升级到带有嵌入式连接的v0.8.1。但是，ksqldb-server在从以下日志开始后崩溃：
ksqldb-server | [2020-04-07 07:24:37,266] ERROR Error during restore (io.confluent.ksql.rest.server.computation.CommandRunner:191)
ksqldb-server | org.apache.kafka.common.errors.SerializationException: Err
浏览 2提问于2020-04-07得票数 1
回答已采纳
使用汇合5.4.1
我们碰巧在将连接流从KTable KTable转发到另一个主题时，在新的KTable外键连接中遇到了一个问题。
模式注册表和Avro序列化器相关构件:合流版本5.4.1 kafkastreams客户端: 5.4.1-ccs
外键跨ktable连接之后，虽然使用“for each”从ktable消费流，但如果使用“to”将联接流转发到另一个主题，则会引发模式注册表错误。
将错误中提到的模式与在模式注册表中注册的模式进行比较，它是完全相同的…。似乎卡夫卡2.4.0已经有了类似的问题：和这个问题继续存在，同时将它转发到另一个主题
Caused by: io.confluent.k
浏览 5提问于2020-03-16得票数 0
回答已采纳
我在我的笔记本电脑上旋转了一个Kafka in Docker (带有docker-compose)。
之后，创建了新的kafka主题：
kafka-topics --zookeeper localhost:2181 --create --topic simple --replication-factor 1 --partitions 1
(尚未在架构注册表中创建架构)。
现在尝试生成(基于此示例-步骤3- )：
kafka-avro-console-producer \
--broker-list localhost:9092 --topic simple \
浏览 0提问于2018-04-24得票数 2
我正在尝试生成Confluent的Kafka虚拟数据生成器消息给Elasticsearch：
datagen (从获取的avro文件)的初始化：
./bin/ksql-datagen schema=~/impressions.avro bootstrap-server=host009:9092 format=json key=impressionid topic=impressions2 maxInterval=1000
连接器的初始化
./bin/connect-standalone ./etc/schema-registry/connect-avro-standalone.properti
浏览 0提问于2018-11-01得票数 0
回答已采纳
1回答
我有一个码头组成文件来建立卡夫卡的基础设施。问题是，当我第一次在机器上运行对接-撰写，那么所有的容器运行良好，但当我停止/移除容器并重新运行码头-撰写，然后图像容器"cnfldemos/cp-server-connect-datagen:0.2.0-5.4.0“得到一个出口。我只是想更新一下，这个问题不是常量的，我无法找出根本原因。
请您帮我解决上面关于图像容器"cnfldemos/cp-server-connect-datagen:0.2.0-5.4.0".的问题。通过查看日志，我知道有一个未知的主机期望，但我不知道它为什么要查找172.18.0.4IP。这甚至不是我
浏览 1提问于2020-04-03得票数 2
回答已采纳
我是apache kafka的初学者，正在尝试学习confluent - kafka - rest - utils，但是我对如何使用它感到困惑。
在搜索过程中，我找到了这个文档
这是一个非常好的文档，但它不能帮助我学习rest-utils。
confluent kafka rest实用程序的git代码是
正在演示如何使用rest kafka。但我想知道确切的程序，以便更好地了解它。用一些简单的解释。谁能给我一些建议，我如何使用rest客户端的链接。请引导我走向这一点。
这可能是一个愚蠢的问题，但我没有其他选择去学习。
提前谢谢。
浏览 3提问于2015-05-29得票数 8
我试图用卡夫卡-连接一个rabbitMQ连接器来验证概念。基本上，我有两个简单的spring引导应用程序:一个RabbitMQ生产者和一个卡夫卡消费者。使用者无法处理来自连接器的消息，因为它正在以某种方式转换我的JSON消息；RabbitMQ发送{"transaction": "PAYMENT", "amount": "$125.0"}和kafka-connect打印X{"transaction": "PAYMENT", "amount": "$125.0"}。请注意
浏览 0提问于2020-01-07得票数 1
回答已采纳
我编写了docker-compose.yml文件来创建以下容器：
合流-动物园管理员
合流-卡夫卡
合流-模式注册表
我想要一个单一的码头-合成文件，以旋转必要的容器，公开所需的端口和互连依赖的容器。目标是让我使用来自码头枢纽的官方合流图像。我的停靠撰写文件如下所示：
zookeeper:
image: confluent/zookeeper
container_name: confluent-zookeeper
hostname: zookeeper
environment:
ZOOKEEPER_CLIENT_PORT: 2181
ports:
浏览 2提问于2017-05-17得票数 0
1回答
我遵循Confluent的指南，并使broker和zookeeper服务都使用了命名的卷。显然，connect服务的所有数据都在broker上，所以我不需要让connect使用指定的卷。
然而，当我运行docker-compose down，然后运行docker-compose up时，卡夫卡连接器都没有恢复。主题被恢复，因此命名的卷正在为broker工作。
如何使docker-compose down不删除卡夫卡连接器？这是我docker-compose.yml的一部分
---
version: '3.8'
services:
zookeeper:
image:
浏览 3提问于2022-05-15得票数 0
2回答
正在尝试将数据从kafka写入hdfs。没有文档说明如何使用Confluent的kafka-connect-hdfs Java API。
浏览 0提问于2016-08-11得票数 3
2回答
安装目录
、、
我为Ubuntu 16.04 of confluent 4.1安装了quickstart包，我能够通过quickstart罚款。但是，有些事情需要设置env变量：
$CONFLUENT_HOME is not defined. Run 'export CONFLUENT_HOME=/path/to/confluentplatform'
我看了看：
/opt
/usr/local
/usr/lib
但无处可寻。然后我试着：
idf@idf-vb:~$find / -iname confluence 2>&1 | grep -v "Permission de
浏览 3提问于2018-05-24得票数 0
1回答
我正在尝试让模式注册表运行，并且我看到了下面的异常。
ERROR Server died unexpectedly:
(io.confluent.kafka.schemaregistry.rest.SchemaRegistryMain:51)
org.apache.kafka.common.config.ConfigException: Only plaintext and SSL Kafka endpoints are supported and none are configured.
at io.confluent.kafka.schemaregistry.st
浏览 0提问于2018-11-07得票数 1
我正在尝试配置模式注册表来使用SSL，我已经有了动物园管理员和kafka代理使用相同的SSL密钥。但是，每当我启动模式注册表时，我都会得到以下错误
ERROR Error starting the schema registry(io.confluent.kafka.schemaregistry.rest.SchemaRegistryRestApplication)
io.confluent.kafka.schemaregistry.exceptions.SchemaRegistryInitializationException: Error initializing kafka
浏览 3提问于2020-04-05得票数 1
下面是JDBC Sink连接器的有效负载
connector.class=io.confluent.connect.jdbc.JdbcSinkConnector
table.name.format=Subs_V1
behavior.on.null.values=ignore
connection.password=***********
topics=Subscription
task.max=1
batch.size=500
value.converter.schema.registry.url=http://localhost:8081
auto.evolve=true
connectio
浏览 33提问于2022-01-19得票数 3
回答已采纳
我曾尝试通过使用confluent zip / tar文件安装ksql服务器和客户端来创建流，并且成功了。例如，下面日志中的create stream语句使用ksql-cli运行得很好。
但是，当我在链接之后使用docker-compose up启动ksql服务器时(通过关闭之前的ksql server )，它给出了下面的错误，可能是因为这个ksql cli没有使用docker exec -it ksqldb-cli ksql http://0.0.0.0:8088连接到ksql server，并给出了错误Couldn't connect to the KSQL server: KSQ
浏览 0提问于2021-01-13得票数 1
我正在尝试理解一个 (也显示在这篇文章的底部)。
问题： confluent:2181使用以下行
KAFKA_ZOOKEEPER_CONNECT: "confluent:2181"
这个confluent主机名是如何定义的？如果我正确理解了Docker中的主机名，那么惟一的容器主机名是zookeeper、kafka、rest-proxy和schema-registry。
docker-compose.yml
version: "2"
services:
zookeeper:
image: confluent/zookeeper
浏览 0提问于2018-12-02得票数 0
回答已采纳
卡夫卡主题(test3)
$ kafka-console-consumer --bootstrap-server broker:9092 --topic test3 --from-beginning
"Can we write to a topic that does not exist?"
"Can we write to a topic that does not exist?"
{"foo":"bar"}
["foo","bar"]
confluent
confluent
confluent
浏览 0提问于2018-12-31得票数 1
回答已采纳
1回答
我正在编写POC，我必须读取管道分隔的值文件，并将这些记录插入ms sql server中。我使用Content5.4.1来使用value_delimiter创建流属性。但它的例外：Delimeter only supported with DELIMITED format
1.开始汇合(版本: 5.4.1)::
[Dev root @ myip ~]
# confluent local start
The local commands are intended for a single-node development environment
only, NOT for pr
浏览 2提问于2020-03-11得票数 0
我想从Kafka主题推送数据到REST端点。(非企业版，不使用confluent kafka托管服务)。
我正在考虑使用Confluent的Kafka Connect HTTP接收器，但我意识到它有30天的试用期，之后它需要许可证。
是否有其他开源/免费选项可用作Apache Kafka和REST API之间的双向桥梁。
浏览 4提问于2021-07-19得票数 0
我已经从Confluent安装了Apache Kafka (使用rest-api和schema-registry)。我使用spring-boot和spring-kafka实现了producer (每个事件都在数据库触发器中生成了uuid )。现在我想把它作为多个实例来运行--但是在kafka中省略重复的正确方法是什么呢？如果我在负载均衡器后面有几个spring-boot实例，并且每个实例都有相同生成的uuid的事件，如何只发送一个到kafka？我可以在spring中生成uuid，但是事件的内容仍然是相同的，并且没有必要从每个实例发送它(数据库的触发器无论如何都会将内容发送给每个生产者)。
浏览 0提问于2017-12-13得票数 0
我在TopologyTestDriver上遇到了一个问题，因为设置属性是必须的:当拓扑试图将记录发布到主题中时，它会转到配置中提供的"url“。我如何才能模拟指向MockedSchemaRegistry的访问？
要将avro中的记录写入主题，请使用mockSchemaRegistryClient.register
还有一个问题，我如何将stateStore加载到拓扑中？我正在初始化时创建stateStore (主题已经创建)
我的亲信：
testImplementation("org.junit.jupiter:junit-jupiter-api:5.3.1")
浏览 1提问于2018-10-17得票数 2
回答已采纳
Caused by: org.apache.kafka.common.errors.SerializationException: Error retrieving Avro schema for id 1
Caused by: io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException: Subject not found.; error code: 40401
Confluent版本4.1.0
我使用KTable消费来自几个主题(topic_1，topic_2)的数据，连接数据，然后使用KStre
浏览 0提问于2018-05-25得票数 2
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM活动推荐
腾讯云开发者
