-
Kafka Connect消费者组滞后指标?
我正在运行一个Kafka Connect接收器。我想对此进行监控。 我可以通过炮轰经纪人并像这样使用<code> -
有没有一种方法可以在kafka-console-producer.sh中添加标题
我想使用kafka-console-producer.sh触发一些带有Kafka标头的JSON消息。 这可能吗? <pre><code>firebaseUser.g -
如何配置docker-compose以便将磁盘安装到folder,而不是本地磁盘
我们正在Docker上使用单节点基本部署,其中包括以下服务 <pre><code>kafka schemaregistry zookeeper </code></pre> -
更改为kafka_2.11
我已将pom文件中的Kafka版本从2.10更改为2.11,现在我遇到错误了 pom的变化 来自 <pre><code><depen -
如何在容器外部调整/编辑/添加/更改kafka docker容器参数
我们有以下kafka docker容器(在Linux redhat 7.5上) 我们根据-<a href="https://docs.confluent.io/5.0.0/installation/ -
Kafka集群是数据库吗?
<ol> <li>集群是什么意思?</li> <li>医生说<code>The Kafka cluster *stores* streams of records in categories called topics</code> -
Pyspark无法找到数据源:kafka
我正在研究Kafka流,并尝试将其与Apache Spark集成。但是,在运行时,我遇到了问题。我收到以下错误。</p -
是否可以使用密钥和分区使用kafka消息?
我正在使用<strong> kafka_2.12 </strong>版本<strong> 2.3.0 </strong>,其中我使用分区和密钥将数据发布到kafka主题 -
Kafka DSL KStream变压器之间的Kafka共享状态存储
我有一个拓扑,其中我使用Transformer聚合对象,后来在我的拓扑中,我尝试从第一个Transformer中使用的状 -
spring-cloud-stream-binder-kafka-streams不使用来自kafka的消息
我正在尝试通过spring-cloud-stream-binder-kafka-streams库通过一个简单的Spring引导应用程序使用Kafka中某个主题 -
KafkaStreams:如何在应用启动前分配偏移量
在执行程序之前,如何消耗我指定的偏移位置? 我试图阅读很多文档,但没有找到解决方法。 -
Kafka / Kubernetes和自动缩放
我有一个关于Kubernetes中的Kafka的问题,特别是自动缩放... 假设我在Kubernetes的3个Pod中有3个Kafka经 -
kafka +融合控制中心+如何获取非企业版
我们按照以下步骤安装了Docker融合控制中心 <pre><code> $ docker run -d \ --name=control-center \ --net=confluent -
当主Redis发生故障并且从节点被选择为Sentinel-Redis群集中的主节点时,如何确保Redis节点中的数据一致性
我有一个哨兵-redis设置,其中有3个哨兵(法定人数2)和3个redis节点(1个主控2个从属)。我有一个使用J -
如何轮询kafka时间戳少于30秒的消息?
我只想轮询产生时间少于30秒的记录。在Kafka轮询中,有什么方法可以只消耗少于30秒的消息吗? -
可从Kafka Streams应用程序查询KSQL状态吗?
是否可以从单独的KStreams应用程序中通过键查询KSQL KTable?或者换句话说,可以通过编写另一个应用程序 -
Kafka Streams-杰森
我正在考虑执行以下操作。 <ol> <li> Topic1具有JSON数据 例如:<strong> <code>{"name":"alice -
初始化SpringBoot应用程序时出错。我有一个SpringBoot应用程序。 2.1.5使用Kakfa的发布
我有一个SpringBoot应用程序。 2.1.5.RELEASE,它使用IntelliJ IDEA将Spring用于Apache Kafka(基于Kafka的消息传递解 -
Spring Cloud Streams-Apache Kafka活页夹-Avro反序列化异常-使用者
将<code>@StreamListener</code>注释与Apache Kafka Binder + Spring Cloud Streams一起使用时,推荐的处理反序列化异常的 -
跨目录的跨Kafka主题分区
我有一个带有一个分区的Kafka主题。我正在尝试向经纪人发送消息。源大小为1.5 TB。我的经纪人有两个目 -
无法使用AdminClient deleteTopic删除Kafka主题
我正在使用<strong> Kafka_2.12 </strong>版本<strong> 2.3.0 </strong>。为了删除主题,我使用下面的代码段 <pre>< -
Kafka客户端在Broker集群加载期间重新平衡
我提供了很多服务,在经纪人负担很重的情况下,Kafka客户会进行大量的重新平衡。这些经纪人由一个集 -
Kafka是否提前保留磁盘空间?
我刚刚完成了一次测试,以查看我的单节点Kafka集群(1个Zookeeper,1个Kafka-Broker)如何处理未来项目的预 -
春季Kafka的收听者反复收听失败的Kafka主题消息
我正在将Spring Kafka与Spring Boot 2.1.9一起使用,并将confluentinc / cp-kafka:5.3.0(群集的3个brokers)作为Broker。 -
Kafka转S3连接器
假设我们在独立模式下使用Kafka S3接收器连接器。 正如写在融合页面上一样,它只有一次交付保证。 我 -
卡夫卡主题顺序
我有一个Kafka连接器,使用的是以下内容: <pre><code>SELECT CAST ( id as VARCHAR) as key_id, id ... FROM table1 JOIN -
腐败的动物园管理员
设置:3个节点群集。每个节点都有一个动物园管理员和Kafka。 试用Kafka时,我们在5分钟内创建了1 -
群集中3台Linux不同计算机上的Confluent Platform Docker群集
我们正在搜索说明如何通过docker在3个不同的Linux计算机上以群集方式安装Confluent平台的文档 我们 -
合计架构注册表UnknownTopicOrPartitionException:此服务器未托管此主题分区。
全新服务器,全新安装的confluent-community-2.12版本5.3.1。 架构注册表配置有<code>/etc/schema-registry/schema -
有关分配偏移量时的错误的问题
我编写了一个Kafka使用者函数,该函数首先从读取的最后一个偏移量中检索消息,然后开始使用下一个偏