apache-kafka,
我有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 = &#34;#&#34;, group = &#34;#
是否可以指定debezium postgres连接器从特定记录读取,而不是从postgres表的开头读取。我们正在debezium kafka
我有一个Avro方案,其中有100个字段,在这些字段中,一个字段的数组类型如下所示 <pre><code>{&#34;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