我有一个消费者应用程序，它期望JSON像这样：<code>{"timestamp":1554138000,"level":"first","m
我要求在哪里需要一个Spring Boot Rest Service，客户端应用程序每30分钟将调用一次，服务将返回
<ol>
<li>
我有Kinesis流托管在AWS云上，我想将此数据存储到Google云托管的现有Kafka主题中。我不确定连接这两个云
有3个kafka服务器
在所有3台服务器上设置<code>/etc/hosts</code>。
<pre><code>192.168.0.1 kafka1
192.168.0.2 ka
我有一个执行某些状态处理的微服务。该应用程序从输入主题构造一个KStream，进行一些有状态的处理，
<a href="https://github.com/quarkusio/quarkus-quickstarts/tree/master/kafka-quickstart" rel="nofollow noreferrer">Kafka quickstart</a>
我有一个Kafka Avro主题，数据采用以下格式。
<pre><code>Sample data
{'model_id': 'tesla_model_s'} {&#
我试图查看GlobalKtable在kafka中的工作方式，为此，我试图编写示例代码。
我已经创建了globalKtable，但我
我使用<a href="https://camel.apache.org/manual/latest/route-policy.html" rel="nofollow noreferrer">Camel RoutePolicy</a>“监视”
我有一个流，它使消息映射到两个不同的map（）调用，并进一步被过滤并写入两个不同的主题。
<pre><
我正在研究其中有2个群集的作品，可以将它们称为DC1和DC2，每个群集上都运行Mirrormaker 2。我在每个节点
我有一个要求，我需要以编程方式创建和删除Kafka主题。 <code>org.springframework.cloud.stream.binding.BinderAwareChan
我们正在尝试从本地分区移动到远程分区。我们面临的问题是远程步骤分区无法并行运行。
下面是
我需要为以下数据编写一个Avro模式。曝光是一个由3个数字组成的数组。
<pre><code>{
"Response": {
我对kafka connect S3接收器连接器有多个疑问
1。我想知道是否可以使用kafka的S3接收器来保存具有多
我有一个带有3个节点的Kafka集群（每个节点具有32GB Ram）和将近50个主题
最近，这台机器中的一台
我们确实有kafka生产者构建应用程序。我需要为它编写集成测试用例。我试图使用DockerImageName和嵌入式kaf
我从csv文件向kafka写消息。我的生产者说所有数据都以Kafka为主题。
此外，我使用apache nifi作为kafka
我正在使用Kafka Connect来流化具有250,000,000条记录的数据库。从源头读取没问题，它在不明显的时间内被
Clickhouse如果是纯JSON文档，肯定可以从Kafka读取JSON消息。
我们在Clickhouse中用<code>kafka_format = 'JSO
