卡夫卡流是好的，但我必须做每一个配置非常手动。相反，Kafka提供了它的API接口，它对于处理配置以及任务、工作人员等都非常有用。
<em
浏览 11提问于2021-04-26得票数 0
1回答
有两个主题，source_topic.a，source_topic.b。source_topic.a与source_topic.b有依赖关系(例如。首先需要沉掉source_topic.b )。是否有任何方法在源/接收器配置中设置主题/表的顺序？
下面是使用的配置，有多个表和主题。时间戳用于每次轮询表时更新表的模式。timestamp.initial将值设置为特定的时间戳。
浏览 2提问于2020-11-26得票数 1
回答已采纳
我的场景是我使用了很多相同前缀的卡夫卡主题。house.door，house.room )，并使用Kafka流regex主题模式API来使用所有主题。一切看起来都很好，我得到了数据的密钥和信息。为了处理数据，我需要主题名，所以我可以基于主题名进行连接，但是我不知道如何在Kafka流DSL中获取主题名。
解决我的问题的一个可能的方
浏览 0提问于2018-01-19得票数 4
回答已采纳
1回答
Kafka JDBC connect兼容Spring-Kafka库吗？
我确实关注了，但仍然有一些困惑。
浏览 4提问于2020-07-04得票数 0
我需要写一个java应用程序，从Kinesis流读取和存储数据到Kafka主题。我不能使用连接器，我必须使用Kafka Streams，因为其中涉及到很多逻辑。Kafka Stream是否可以直接从Kinesis流读取，或者我必须先将数据存储到Kafka topic才能被Kafka Stream读取？我读了很多关于Kafka Streams的文章，除了Kafka<
浏览 18提问于2019-07-29得票数 1
我注意到，当我的Kafka流应用程序有一段时间没有阅读来自Kafka主题的新消息时，它就停止工作了。这是我第三次看到这种情况发生。
自5天以来，没有向该主题发出任何信息。我的Kafka应用程序，也是一个星星之火的java java服务器，仍然有响应能力。然而，我对卡夫卡主题产生的信息不再被卡夫卡流所阅读。当我重新启动应用程序时，所有消息都将从代理中获取。我如何使我的卡夫卡流应用程序更持久的这种情况？它认为卡夫卡<em
浏览 0提问于2018-04-05得票数 0
假设我们有一个Kafka Sink连接器从主题TopicA中填充一个数据库，由Sink连接器更新到数据库中的数据，以及执行更新的
受Kafka流应用程序提交间隔的影响，如果是，如何影响？
浏览 4提问于2020-04-25得票数 0
回答已采纳
1回答
我是麋鹿堆栈的新手，我只是想知道是否可以使用Kafka将日志文件发送到Elasticsearch。，但我也需要用 grok 这样的过滤器来解析日志。是可能的吗？谢谢您:)
注意:我试图做的是Ship +分析在Kafka中的日志。我知道使用elasticsearch连接器可以将日志发送到Elasticsearch，但我想问的是，使用Kafka是否可以解析数据(Logstash的工作)。
浏览 0提问于2018-07-18得票数 3
回答已采纳
有兴趣将数据从kafka转移到elasticsearch。所以我设置了。尽管我查看了所有文档和，但我仍然找到了如何配置连接器，以便将数据从kafka移动到elasticsearch (接近于实时)。也就是说，让连接器每秒使用来自( kafka )主题的消息，并将它们写入elasticsearch，模拟从kafka流到elasticsearch的消息流。这是连接器的当前配置： "na
浏览 1提问于2020-02-18得票数 0
2回答
基于并行度管理的Kafka流容错
、、、、
Description：在使用了卡夫卡主题的事件之后，我有一些线程并行地写到s3。由于一些业务应用逻辑和处理，没有使用kafka-连接器-S3。我希望应用程序是容错的，不想丢失消息。主题的消息。在崩溃场景中，我应该如何处
浏览 4提问于2020-11-23得票数 0
1回答
Kafka用例替换控制M作业
、、、、
目前，我们使用apache骆驼来完成这个任务。创建csv kafka源连接器来读取csv中的数据，并插入kafka输入主题创建春云kafka流绑定应用程序，从输入主题读取数据，丰富数据并将数据推送到输出主题，让kafka接收器连接器将数据从输出主题推送到数据库现在问题二，我们需要有数据库连接</em
浏览 1提问于2021-05-14得票数 0
1回答
我已经创建了一个连接器来处理Avro数据。我能够将数据发布到一个主题中。但我不会将数据输入到输出主题中。我已经检查了连接器和rest代理的日志，没有显示错误。connector.class": "io.confluent.connect.http.HttpSinkConnector",
"headers": "Content-Type:application/vnd.kafka.json.v2+json|Accept:a
浏览 7提问于2022-04-01得票数 0
我有Mule应用程序，并使用Apache Kafka连接器连接主题。mule-kakfa连接器jar是"mule-module-kafka-2.1.0.jar“连接器使用producer.properties和consumer.properties文件，这些文件包含纯文本形式的你能建议如何加密这些密码和使用在mule流程中。Mule Kafka连接器代码
浏览 42提问于2019-06-11得票数 0
1回答
卡夫卡连接器中有可能为单个接收器连接器提供多个转换器吗？例如，我们有一个用例，在该用例中，我们以格式A接收来自主题的数据，但希望将其流到两个位置，一个是格式A，另一个是格式B。在一个连接器中可以做到这一点吗？
浏览 1提问于2017-10-12得票数 0
回答已采纳
1回答
我们有一个CSV文件格式的业务事件，需要使用Kafka附加到数据库(在我们的例子中是雪花)。我们是否需要将csv文件转换为JSON格式(使用python)，然后将值传递给kafka-producer主题？
浏览 5提问于2020-05-25得票数 0
回答已采纳
如果没有联接，我从中间主题"book-attribute-by-id“中阅读就没有问题。用于KStream的示例msg： value: {id: 1, book_id: 1, attribute_id: 1, value: 200}} });
线程"xxx-StreamThread-1“org.apache.ka
浏览 1提问于2019-02-06得票数 0
回答已采纳
我是卡夫卡流的新手，我一直在阅读关于如何设置卡夫卡流应用程序的。
不过，我不清楚数据是如何处理的--什么存储在内存中，什么存储在磁盘上。我有2个Kafka主题，两个键值存储类型，为每个键保留最古老的值。在我的streams应用程序中，我想将这两个主题连接起来，并将连接输出回kafka，稍后可以被一些接收器使用。我担心的是，不清楚连接是如何执行的。这两个主题
浏览 3提问于2017-08-23得票数 7
回答已采纳
Apache Beam和Apache Kafka在流处理方面有什么不同？我也在努力掌握技术和编程上的差异。
请通过您的经验报告来帮助我理解。
浏览 1提问于2018-06-15得票数 10
1回答
我从未使用过AMQ Streams (Kafka)。如何通过路由(读取/创建/删除)连接到主题？对于Kafka，例如在我的本地机器上，我使用带有基本命令的CLI。但是对于AMQ流，我只有路由。
浏览 4提问于2020-06-01得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
