我正在使用ElasticsearchSinkConnector将数据从Kafka主题存储到Elasticsearch索引。这是一个Kafka消息的示例：
<p
我正在尝试使用<code>Kafka-Connect</code>在本地运行<code>docker-compose</code>。正如我喜欢Confluent产品和Kafka一样
我目前正在尝试以分布式模式在kafka-connect集群上配置elasticsearch sink连接器。使用汇合提供的Helm图表将此
我们有一个Kafka-> Kafka Connect-> PostgreSQL堆栈，该堆栈将来自数十个主题的数据连续不断地从Kafka写入PostgreS
我将kafka-exporter配置为从Kafka代理获取指标。
但是Prometheus中缺少Kafka指标。
我在kubernetes中使用prometheus-op
我已经为主题注册了以下Avro模式：
<pre><code>{
"type": "array",
"items": "com.example.Us
我们正在尝试优化我们的python应用程序，该应用程序通过融合的python kafka客户端向kafka主题生成消息，并
我正在编写使用confluent_kafka api（内部使用librdkafka）计算kafka吞吐量的python应用程序，但是在此过程中，
我们目前正在使用5.3.1 kafka，我们需要升级到5.3.2。
我们使用孵化器头盔图在k8的集群中设置kafka节点。</
嗨，我们的kafka崩溃了大约2天，而我们的一位使用融合kafka进行python的生产者仍然尝试生成消息，而我们
当我尝试基于基于Kafka运算符的安装来设置Kafka集群时，没有成功，并停留在KSQL，Schema Registry，Control Cent
我目前正在熟悉Docker并更好地了解它。
<strong>摘要</strong>：这是关于Docker容器与Confluent Kafka Producer
我有一个Spring boot kstream应用程序，该应用程序使用来自主题的消息并将其存储在文件中。
该应用
在Confluent控制中心中，我可以看到“连接”选项卡。我为所有配置添加了一个弹性搜索接收器连接器。
我们正在尝试在顶级eks集群上进行基于操作员的Kafka安装。我们能够成功安装Operator，Zookeeper，Kafka。但
当我们尝试安装架构注册表操作器时，根据以下步骤未创建Pod。请帮助我们解决此问题。
<pre><code>- sc
简而言之，我启动了Kafka，成功创建了一个主题，启动了启用了密钥的制作人。到现在为止还挺好。我发
我正在使用 Confluent Source 连接器将数据从 Postgres 复制到 Kafka。
我想到了以下技巧来在每个运行周
问题是，我将使用 KSQL 将原始 kafka 主题架构更改为新的嵌套架构
这是我当前的 kafka 主题架构和字段：</
我正在尝试从 kafka 中了解从 neo4j 流发送到一个 kafka 主题的接收模型。
实际上，这些数据如下所示
