我有AWS MSK Kafka群集（仅TLS），并且我想限制所有tls用户的主题创建/删除。
问题：目前，我可以创
我已经使用位图图表将Kafka部署为Kubernetes吊舱。
Kafka版本2.3.0
<pre><code>[2020-08-10 16:08:22,515] INFO Client en
在负载测试后的一个测试环境中，我的场景中我们的kafka分区的偏移量分布不均匀。如果它偏离了几百个
我认为使用lambda消耗进入AWS MSK Kafka集群中某个主题的消息是微不足道的，但是我找不到从AWS文档中做到
我想将Lambda函数附加到AWS MSK Kafka集群中的主题，但是根据我在AWS文档中了解的内容，这还不可能。
<p
我试图运行具有5个工作人员和2个接收器连接器的Kafka Connect分布式集群。一个连接器配置了最大任务，
我已经发布了一个问题<a href="https://stackoverflow.com/questions/63310003/when-enablesslcertificateverification-is-set-to-true-
当我尝试连接到我的Kafka经纪人时，看到以下错误消息：
<pre><code>2020-08-10 15:59:54.974 ERROR 31447 --- [ sch
我有一个消费者主题-发送数据的电子邮件地址，我想提取特定日期的python数据格式（JSON格式）。请给我
我们有2个不同的数据中心（DC-A和DC-B），它们之间没有连接。实际上，仅允许从DC-A到DC-B的入站流量。我
我正在使用spring提供的@kafkaListener注释来创建kafka容器
<pre><code>@KafkaListener(topics = "#", group = "#
是否可以指定debezium postgres连接器从特定记录读取，而不是从postgres表的开头读取。我们正在debezium kafka
我有一个Avro方案，其中有100个字段，在这些字段中，一个字段的数组类型如下所示
<pre><code>{"name&#
从<a href="https://docs.confluent.io/current/quickstart/ce-docker-quickstart.html" rel="nofollow noreferrer">Confluent Platform (Docker)
我们正在使用AWS SQS，并希望使我们的应用程序与云无关。因此，希望用Kafka取代SQS。
是否存在具有
为了了解CDC管道的模式演变，我试图将头绪围绕在以下<a href="https://docs.confluent.io/3.0.0/connect/connect-jdbc/doc
在Snowflake kafka连接器中，我可以使用预定义的数据类型，因为在内部它使用Snowpipe来加载数据。
我
我在使用FlinkKafkaConnector时遇到困难。
尽管我已经导入了<code>org.apache.flink.streaming.connectors.kafka.FlinkK
我有一个简单的Flink Scala流媒体作业，该作业连接到Kafka主题并映射其主题
<em> org.apache.avro.generic.Ge
我决定通过Prometheus和Grafana来监控我的卡夫卡消费者的滞后时间。
我的计划是kafka应用程序-kafka出口商-Pr
