将子串替换为另一个子串的Kafka单消息转换
Kafka单消息转换是一种在Kafka消息队列中实现子串替换的操作。它可以通过将一个子串替换为另一个子串来修改消息内容。这种转换可以在消息传递过程中对消息进行实时处理和修改，从而满足特定业务需求。
Kafka单消息转换的分类： Kafka单消息转换可以分为两种类型：消息内容转换和消息格式转换。
- 消息内容转换：这种转换主要针对消息中的文本内容进行替换操作，可以根据指定的规则将特定的子串替换为另一个子串，从而实现内容的修改。
- 消息格式转换：这种转换主要针对消息的结构和格式进行修改，可以根据不同的需求对消息的字段进行增删改操作，从而实现消息结构的调整和转换。
Kafka单消息转换的优势：
- 灵活性：Kafka单消息转换可以根据业务需求灵活地对消息进行修改，满足不同的处理需求。
- 实时性：转换操作可以在消息传递的过程中实时进行，无需等待消息的存储和读取，从而减少处理延迟。
- 可扩展性：Kafka单消息转换可以通过编写自定义的转换逻辑来满足特定的处理需求，具有很强的扩展性。
Kafka单消息转换的应用场景：
- 数据清洗：通过替换子串可以清洗消息中的脏数据或敏感信息，保证数据的质量和安全性。
- 数据格式转换：可以将消息中的字段进行转换，使其适应不同的数据消费者的需求。
- 动态配置：可以根据实时的业务需求，动态地修改消息内容，实现动态配置的效果。
腾讯云相关产品和产品介绍链接地址：
- 腾讯云消息队列 CMQ：https://cloud.tencent.com/product/cmq
- 腾讯云云原生容器服务 TKE：https://cloud.tencent.com/product/tke
- 腾讯云云服务器 CVM：https://cloud.tencent.com/product/cvm
- 腾讯云对象存储 COS：https://cloud.tencent.com/product/cos
请注意，以上产品仅作为示例，并非推广或广告。您可以根据实际需求选择适合的产品。
相关·内容
1回答
为了满足要求，我们将按照数据管线的要求进行组装。
IBM (Source) -> Kafka连接->流API (Kafka/Flink/Spark) -> DB (Sink)。
我想检查是否有在Kafka层或消息到达kafka/kafka连接集群之前执行消息编码转换(定制)的选项。
该选项不应将重大延迟添加到数据管道行。
浏览 1提问于2019-03-04得票数 0
回答已采纳
JSON消息正在由字符串使用者使用。我的produces发送两种类型的消息字符串和序列化的JSON
@KafkaListener(topics = "${kafka.topic}", groupId = "${kafka.group-id}", containerFactory = "${kafka.string-listener-container-factory}")
public void consume(@NotNull ConsumerRecord<String, String> cr, @Payload String pa
浏览 0提问于2020-02-13得票数 1
奇怪的问题。由于某些原因，stdout中的值没有被正确识别。我想要做的是对正在监听的端口的grep值进行匹配。如果存在定义的端口(即被监听，产生一条消息，如果没有，则生成另一条消息)。
---
- name: check_prometheus_status_kafka
shell: /usr/sbin/ss -lnt|awk '{ print $4}'|grep 9071 |sed 's/\*//'| sed 's/\://'
register: prom_status
- debug: var=prom_status.s
浏览 1提问于2017-11-02得票数 0
回答已采纳
我有一个场景，在消息到达kafka之前，我需要更改从JDBC源连接器获得的消息结构。我是kafka的初学者，所以kafka streams如何帮助我实现这一点。
输入-
{"id":"123","firstName":"pqr","lastName":"xyz","age":"23","dob":"20-09-1995"}
我想将其存储在弹性索引中，如下所示
{"id":"123","name&
浏览 0提问于2018-09-21得票数 0
我有一个简单的JSON对象，如下所示
d = { 'tag ': 'blah',
'name' : 'sam',
'score':
{'row1': 100,
'row2': 200
}
}
下面是我向Kafka发送消息的python代码
from kafka import SimpleProducer, KafkaClient
import json
# To send messages synchronously
kafka = Kaf
浏览 0提问于2015-08-05得票数 4
回答已采纳
如果我使用kafka-connect来消费消息并将其存储到s3 (使用kafka-connect s3连接器)，是否可以将消息偏移量与事件有效负载一起存储？我希望有这些数据，以便对消息进行排序，并检查是否可能有任何差距或检查是否有任何重复的消息，我已经收到。(例如，如果我的消费者偏移量意外崩溃，我重新启动了kafka-connect)。这是可能的，还是我应该为这种类型的功能编写一个自定义订阅者？
浏览 13提问于2020-05-13得票数 2
回答已采纳
我有卡夫卡主题与多种类型的信息流动和写作弹性搜索使用卡夫卡连接。流看起来很好，直到，我必须将唯一的一组消息分成唯一的索引。也就是说，我必须根据字段(是JSON消息)获得新数据集的新索引。
如何配置/自定义Kafka连接来为我做同样的事情？每条消息都包含一个代表消息类型和时间戳的文件。
Json的示例如下: Sample1：{"log":{"data":"information", "version":"1.1"}, "type":"xyz", "timestamp":
浏览 0提问于2019-09-04得票数 3
回答已采纳
我是Apache Kafka技术的新手。我尝试使用python2.7将消息作为JSON对象发送到kafka主题，但是我得到了"AssertionError: Value must be bytes“错误。我可以成功地以字符串形式发送消息，我可以使用kafka-console-consumer.sh查看我的消息。我使用的是apache kafka 2.10-0.8.2.1版本。我在下面给出我的代码。
from kafka import KafkaProducer
import yaml
producer = KafkaProducer(bootstap_servers="loc
浏览 2提问于2016-12-14得票数 11
回答已采纳
我正在使用源连接器从数据库中的视图中读取数据，并将其发布到kafka上，它运行良好。
我的用例是，用户可以创建多个对象，并且对象的顺序在我的应用程序中很重要。我希望使用用户id作为我要发布到主题中的所有消息的消息键，以维护它们的顺序。
我的问题是如何在Kafka连接源连接器中定义消息键？
浏览 1提问于2018-06-21得票数 5
回答已采纳
我的项目中有一个Dot Net Core项目和一些RDLC报告。现在，在RDLC报告中，我需要一个子报告，但没有引发SubreportProcessingEventArgs。有人能帮我在Dot Net Core中添加一个命名空间来识别这种类型的事件吗？
浏览 0提问于2019-02-19得票数 0
1回答
水槽事件被截断了。
、、、、
这里我面临一个问题，我从Kafka源接收消息，并编写一个拦截器从kafka消息(json格式)中提取两个字段(dataSoure和businessType)。这里使用的是gson.fromJson()。但问题是我犯了以下错误。
在这里，我想知道当水槽超过极限时，水槽是否会截断水槽事件？如果是，如何将其设置为更大的值。因为我的卡夫卡信息总是很长，大约60K字节。
期待着回复。提前感谢！
2015-12-09 11:48:05,665 (PollableSourceRunner Apply)错误- org.apache.flume.source.kafka.KafkaSource.process
浏览 5提问于2015-12-10得票数 0
在Kafka的Producer API for Java和Consumer API中有一个org.apache.kafka.common.serialization.ByteArraySerializer类。
如果你在Python中使用Kafka，有没有等价的类？
浏览 10提问于2018-02-16得票数 2
我正在尝试用spark SQL将Avro消息写入Kafka。有人能建议我如何在java中实现它吗？我找到了一个scala参考代码，但没有找到Java。
我试过了，但是抛出了错误，我可以在哪里配置模式注册表。
aggr.selectExpr("CAST(order_id AS String) AS key", "to_avro(struct(*)) AS value").write().format("kafka").option("kafka.bootstrap.servers", "localhost:9092"
浏览 5提问于2020-02-04得票数 0
我正在开发两个带有NestJS和类型记录的微服务，用于在两个不同的队列上消费和发布消息。方案如下：
消费者微型服务从Kafka主题或队列中读取消息。
然后将这个消息发送到第二个微服务。
问题出现在第二步，消费者的微型服务从来不发送信息.
消息消耗是用来自库Consumer的kafka-node实现的。这些消息被正确地使用并且可以被记录。
微服务之间的通信使用来自包RedisClient的@nestjs/microservices进行，并在监听器方法外部执行时工作。
当微服务之间的消息从其他任何地方发送时，我可以在redis-cli MONITOR上看到它们，但是当从侦听器函数
浏览 1提问于2019-05-23得票数 0
回答已采纳
我正在发送有关主题的消息，并且可以使用kafka控制台和Java消费者代码使用main方法读取相同的消息。但是消息并没有从使用者配置xml中读取。请帮助解决这个问题。我正在使用消息int-kafka:消息驱动-通道适配器。春季-卡夫卡1.3.0版
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://ww
浏览 2提问于2015-12-26得票数 1
回答已采纳
我正在发布相同的数据(主题，键和值)从基于python confluent_kafka库的生产者和基于Java apache库的生产者，但当消息检查卡夫卡，然后他们被发布到不同的卡夫卡分区。
我期望在默认情况下，这两个库都将使用相同的散列方法(murmur2)，并在将消息发布到Kafka时确定相同的分区，但看起来这并没有发生。
是否需要在Python库上设置标志或选项，以便它使用相同的算法并生成相同的(与Java库相同的) Kafka分区，或者是否有其他python库可以实现这一点？
浏览 4提问于2020-02-29得票数 0
3回答
例如，我有一个shell变量。A=“大个子男人”。如何在bash中使用regex，打印出只有中间字大写的变量？(大个子男人)
我可以通过将变量分离成3个变量，然后在echo中展开它们。例如first=${a%* }等，但是我如何用一个正则表达式一次完成它呢？
单行就能做到吗？使用大写运算符(^)
浏览 0提问于2019-02-09得票数 3
回答已采纳
1回答
我有一个列表，它是这样的：
Main_List: [ ['1.2','3.5'],[ ['5.8','8.3'] ]
我正在尝试将其中一个子列表转换为浮点数，下面是我所做的：
Main_List[1] = [float(i) for i in Main_List[1]]
但我一直收到错误消息"ValueError: but‘t convert string to float：“
我已经尝试了其他几种方法，但由于某些原因，它一直在抱怨点。我试图转换的列表是从csv文件中提取出来的，但我确实打印了它们，它们看起来很好。
我做错
浏览 2提问于2018-01-29得票数 0
我使用Kafka和Kafka将MySQL数据库复制到MySQL，使用源连接器和汇流JDBC接收器连接器。"auto.create“设置为true，接收器连接器确实创建了表，但有些数据类型不匹配。在SQL Sever中，我有
CREATE TABLE employees (
id INTEGER IDENTITY(1001,1) NOT NULL PRIMARY KEY,
first_name VARCHAR(255) NOT NULL,
last_name VARCHAR(255) NOT NULL,
email VARCHAR(255) NOT NULL UNIQUE
浏览 15提问于2022-03-04得票数 0
2回答
卡夫卡用户-项目设计建议
、、、
我是新鲜的卡夫卡和数据流，并需要一些建议，以下的要求，我们的系统预计接近100万条消息每天。该消息带有一个项目标识符。应该将消息推送给该项目的用户。对于我们的情况，假设我们有项目A、B和C。打开项目A的用户只看到/接收项目A的消息。
到目前为止，这是我对实现需求的解决方案的想法，
消息到达时应该被推送到Kafka主题，让我们把这个主题称为根主题。消息一旦被推入根主题，可以由Kafka消费者/侦听器读取，并且基于消息中的项目标识符可以将该消息推送到特定于项目的主题。因此，任何消息都可能出现在主题A、B或C上。当websockets到达项目用户的仪表板时，考虑使用websockets更新消息。N个
浏览 1提问于2018-01-30得票数 1
我有一个火花结构化流scala作业，它从kafka读取json消息并将数据写入S3。我配置了一个合流模式注册中心，该模式使用type=object的json格式。现在，我可以从注册表中检索模式，但是我需要在包含kafka记录的dataframe上使用这个模式。
val restService = new RestService(schemaRegistryURL)
val valueRestResponseSchema = restService.getLatestVersion(schemaName) // return type is io.confluent.kafka.schemare
浏览 7提问于2022-11-30得票数 0
1回答
我写了一个风暴拓扑图。我基本上想以字节数组的形式将avro模式中的元组发送到kafka主题。
我就是这样下的箭：
builder.setBolt(KAFKA_AVRO_BOLT_NAME, new KafkaBolt<String, byte[]>())
.fieldsGrouping(BOLT1, new Fields("key"));
我就是这样转换成字节数组的
Schema schema = avroObject.getSchema();
DatumWriter<GenericRecord> write
浏览 1提问于2015-03-12得票数 5
回答已采纳
1回答
我需要消费来自6个分区的主题的一些kafka消息。我想用线程来实现，如下所示：
require 'poseidon'
require 'msgpack'
theads = [];
6.times do |partition|
theads << Thread.new {
puts "start thread #{partition}\n"
consumer = Poseidon::PartitionConsumer.new("my_test_consumer", "l
浏览 0提问于2015-04-14得票数 2
2回答
我对Spring kafka Stream是个新手。我最近设置了一个项目，并尝试使用kafka stream API来发布AVRO。需求:需要解析一个复杂的Jsonobject，它可能有多个子jsons。解析Json并为每个子json发送AVRO消息。它也可以是一个或多个。 我知道如何使用kafka客户端API来做到这一点。这很简单，可以用循环来完成，但是用Stream API，我是个新手。 当前stream类的代码如下： @Service
@Log4j2
@EnableBinding(StreamBindings.class)
public class StreamListener {
浏览 38提问于2021-08-12得票数 0
我是卡夫卡-火花流的新手，我试图用协议缓冲串行化/反序列化来实现火花文档中的示例。到目前为止，我一直在关注官方教程
现在我继续讨论下面的问题。这个问题可能与本文的类似。
我已经成功地实现了在kafka主题上写入消息的序列化程序。现在的任务是使用带有自定义反序列化器的火花结构化流来使用它。
public class CustomDeserializer implements Deserializer<Person> {
@Override
public Person deserialize(String topic, byte[] data) {
Person pers
浏览 0提问于2019-07-04得票数 1
回答已采纳
我的用例如下-我有一个包含具有特定ID的消息的主题。我创建了一个Kafka Streams应用程序，它聚合具有相同ID的消息并对它们进行计数(类似于中的示例WordCount实现)。
我希望Kafka流仅在超过特定阈值时才向输出主题发送消息。例如，如果我将阈值定义为10，那么一旦流处理了10条具有相同ID的消息，我就希望将一条消息发送到输出主题。
我知道这可以通过拥有一个额外的主题和另一个处理该主题的流来完成，但是有没有办法在单个流中做到这一点？
浏览 7提问于2020-02-26得票数 0
回答已采纳
注意到一个问题，其中Kafka消费者组(用java实现)始终遗漏了来自代理的几条消息。作为调试的第一行，通过kafka控制台使用者，我可以在代理中看到这些消息。
Kafka broker版本: 0.10.1.0
Kafka客户端版本：
<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka_2.11</artifactId>
<version>0.9.0.1</version>
</dependency>
卡夫
浏览 2提问于2017-12-22得票数 6
1回答
我有一个使用结构化星火流python进行实时处理的任务，所以第一步是将csv文件吞入kafka主题:完成。
第二步是卡夫卡主题的readStream。
df = spark \
.readStream \
.format("kafka") \
.option("kafka.bootstrap.servers", kafka_bootstrap_servers) \
.option("subscribe", kafka_topic_name) \
.option("startingOffsets", &#
浏览 2提问于2021-09-25得票数 1
回答已采纳
是否有一种Pythonic方法来确定一个元组是否是另一个元组的一个片段(而不仅仅是一个子集)？
例如，如果我有以下元组：
t1 = (2, 3, 4)
t2 = (1, 2, 3, 4, 5)
t3 = (3, 4, 2, 5)
那么t1是t2的一部分，但仅是t3的子集。我在找类似"t1 in t2“之类的东西。基于窗口的一个元组沿另一个元组移动是“可实现的”，但可能有一个更有效的方法，我不知道。
浏览 0提问于2020-06-26得票数 1
回答已采纳
我有一个int-kafka:outbound-channel-adapter，用于向kafka发送消息，然后使用int-kafka:inbound-channel-adapter接收消息。沟通似乎很好，我可以发送和接收信息，但格式有点奇怪。我分别向出站适配器发送单独的消息，但是当我收到消息时，我会得到一条消息，并将所有消息聚合到该消息的有效负载中。
当我收到消息时，这就是消息有效负载的样子。
[ headers={id=3934de02-1f42-ab90-6aa5-9c15f3cd0b6e，timestamp=1439260669762} [payload={mytopic={0=stri
浏览 1提问于2015-08-11得票数 1
回答已采纳
我需要写一个java应用程序，从Kinesis流读取和存储数据到Kafka主题。我不能使用连接器，我必须使用Kafka Streams，因为其中涉及到很多逻辑。Kafka Stream是否可以直接从Kinesis流读取，或者我必须先将数据存储到Kafka topic才能被Kafka Stream读取？
我读了很多关于Kafka Streams的文章，除了Kafka主题之外，我从来没有见过Kafka Stream从其他地方阅读的例子。
浏览 18提问于2019-07-29得票数 1
1回答
构造syslog消息时的加扰输出
、、、、
我正在写一个程序，它可以转换已经记录在文件中的标准系统日志消息，例如：
Mar 9 15:51:36 ldaptestserver slapd[392]: slap_global_control: unrecognized control: 1.3.6.1.4.1.42.2.27.8.5.1
添加到包括PRI、header等的系统日志消息中。
我能够从存储在我的kafka测试集群中的syslog消息中做到这一点，它看起来像这样
2017-03-09T15:22:00.642769+00:00 ldaptestserver slapd[392]: slap_global_control: un
浏览 10提问于2017-03-09得票数 3
回答已采纳
我需要在运行时创建Kafka侦听器，一切看起来都正常，除了消息转换器属性似乎被忽略(或者这是一个设计的特性，或者我做错了什么)。
当使用@KafkaListener时，它是正确的，但是当手动创建侦听器时，我的消息没有转换为所需的对象，因此我得到了一个错误：
Caused by: java.lang.ClassCastException: class java.lang.String cannot be cast to class com.my.company.model.MyPojo (java.lang.String is in module java.base of loader '
浏览 3提问于2022-01-12得票数 0
需要一些建议，我已经使用scala创建了一个flink作业来消费来自Kafka的消息。但是消息是用base64编码的。我试过这段代码 val x_stream: DataStream[ObjectNode] = env
.addSource(
new FlinkKafkaConsumer010[ObjectNode](parameters.get("kafka.topic.source"),
new JsonNodeDeserializationSchema(),
kfk_props
浏览 25提问于2021-09-30得票数 0
我试着用库来测试卡夫卡流。
为了测试一个简单的示例，我只想要将字符串转换为大写的。
我尝试下面的代码：
import com.madewithtea.mockedstreams.MockedStreams
import org.apache.kafka.common.serialization.Serdes
import org.scalatest.{Matchers, WordSpec}
class mockedStreamsSpec extends WordSpec with Matchers {
val input = Seq(("x", "foo"
浏览 1提问于2018-03-30得票数 1
回答已采纳
我有一个@StreamListener，它接受@Payload字符串。为了测试这个侦听器类，我使用嵌入式Kafka编写了一个Junit类。我在运行测试类时出错
错误
org.springframework.messaging.converter.MessageConversionException:不能从[B到java.lang.String for GenericMessage )转换
如果我将@Payload的dataType从String更改为byte[]，则侦听器类将选择消息。
谁能帮我知道这是什么问题吗？我想这是云流配置的一部分。
@ExtendWith(SpringExten
浏览 16提问于2019-09-27得票数 1
1回答
我在SpringBoot2.x应用程序中使用SpringCloudStream3.x来使用Kafka主题的消息。
我希望有一个侦听器在某些自定义标头值上有条件地使用消息，如按照
@StreamListener(value = "someTopic", condition = "headers['SomeHeader']=='SomeHeaderValue'")
public void onMessage(Message<?> message) {
LOGGER.info("Received: {}"
浏览 16提问于2020-12-17得票数 1
回答已采纳
2回答
我正在学习一些XSLT函数，并遇到了两个主要名称为translate和replace的函数，我了解到，到最后，这两个函数的任务是替换声明实体上的一些内容(请更多地说明这一点)。
此外，我还编写了一个XSLT，在其中，我希望用如下所示的一组值替换单个值。
<div class="translate">
<xsl:value-of select="translate(current(),' ', 'XXXXX')"/>
</div>
<d
浏览 7提问于2016-08-17得票数 12
我试图使用v1.2.1发送一个基本的字符串有效载荷，但是它失败了，只有以下例外情况：
2015-09-03 11:50:39.729 ERROR 14418 --- [task-executor-3] [ ] o.s.integration.handler.LoggingHandler : org.springframework.messaging.MessageHandlingException: error occurred in message handler [org.springframework.integr
浏览 3提问于2015-09-03得票数 1
回答已采纳
我有一个很长的文本，并且我正在尝试使用开始和结束索引删除多个子字符串。这里的问题是，当我从原始文本中删除第一个子字符串时，其余的开始和结束索引将无效。执行此操作的最有效方法是什么？
def remove_substrings(text, indexes):
'''
indexes is a list containing start and end indexes.
indexes = ["3 5", "7 8"]
'''
return text
浏览 1提问于2020-10-07得票数 0
我使用官方的Kafka RabbitMQ连接器从RabbitMQ实例获取JSOn消息。 目前，此连接器的配置如下 name=RabbitMQConsentConsumer
connector.class=io.confluent.connect.rabbitmq.RabbitMQSourceConnector
rabbitmq.host=HOST
rabbitmq.port=PORT
rabbitmq.username=USER
rabbitmq.password=PASSWORD
rabbitmq.virtual.host=vhost
tasks.max=1
kafka.topic=TOP
浏览 28提问于2019-04-25得票数 2
据我所知，Apache Kafka是异步消息传递平台，而Apache Camel是实现企业集成模式的平台。
那么，Apache Camel和Apache Kafka的实际区别是什么呢？我们计划用Apache Camel实现系统，这相对容易，但我们的客户想要Apache Kafka而不是rational。
选择Apache Kafka实现消息队列功能有什么好处，Apache Camel也可以实现？我担心Kafka只会给项目带来不必要的开销。我们是在比较苹果和橙子吗？
我们需要简单明了的API来设置和使用集群消息队列。我们最初的计划是使用Camel在集群JMS或ActiveMQ队列上消费/生产。K
浏览 4提问于2018-01-30得票数 16
我正在尝试使用Kafka连接器从RabbitMQ队列中读取数据到我的主题中，配置如下：
{
"name" : "RabbitMQSourceConnector1",
"config" : {
"connector.class" : "io.confluent.connect.rabbitmq.RabbitMQSourceConnector",
"tasks.max" : "1",
"kafka.topic" : "rabbitmqte
浏览 17提问于2019-11-27得票数 2
回答已采纳
我正在尝试创建一个带有转换的Debezium MySQL连接器来提取密钥。
在关键转换之前：
create source connector mysql with(
"connector.class" = 'io.debezium.connector.mysql.MySqlConnector',
"database.hostname" = 'mysql',
"tasks.max" = '1',
"database.port" = '3306&#
浏览 2提问于2020-05-20得票数 5
我有一个多主题的S3接收器连接器( topic_a，topic_b，topic_c)，topic_a有字段created_date和topic_b，topic_c有creation_date。我使用下面的transforms.RenameField.renames来重命名字段transforms.RenameField.renames，但是由于唯一的topic_a有created_date，而其他的没有，所以连接器失败了。
我希望将所有消息(从具有单个连接器的所有主题)移动到s3中(如果存在，则将created_date重命名为creation_date )，但是我无法找到正则表达式或转换器来
浏览 0提问于2020-08-06得票数 0
回答已采纳
在验证过程中遇到的错误消息之间，我有以下一个存储过程中的所有分隔符/的现有代码：
;with delimiting_errors
(Id,
Delimited_Error_List)
as
(
select
e2.Id,
'/'
+ (select ' ' + Fn
from Customer e
where e.Id = e2.Id
f
浏览 5提问于2015-08-27得票数 1
回答已采纳
1回答
我试图使用Spring与合流模式注册表和Kafka反序列化器。然而，在“卡夫卡春书”中却没有这样的东西。
以下是我为我的春季卡夫卡消费者做的事情：
@Configuration
@EnableKafka
public class KafkaConfiguration {
@Bean
ConcurrentKafkaListenerContainerFactory<String, Customer> kafkaListenerContainerFactory() {
ConcurrentKafkaListenerContainerFactory<String,
浏览 0提问于2019-07-08得票数 2
我当前的设置包含Kafka、HDFS、Kafka Connect和Schema注册表，它们都位于网络对接容器中。
Kafka主题包含没有模式的简单JSON数据：
{
"repo_name": "ironbee/ironbee"
}
Schema注册表包含一个JSON模式，描述Kafka主题中的数据：
{"$schema": "https://json-schema.org/draft/2019-09/schema",
"$id": "http://example.com/example.json&#
浏览 15提问于2022-11-28得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
