在分布式模式下启动Kafka Connect时出错
我正在以分发模式启动Kafka connect，但收到以下错误...
Kafka指标RequestHandlerAvgIdlePercent
我正在构建kafka指标的grafana仪表板。我的kafka版本...
Kafka GetOffset外壳当t = -2时，除零外将具有不同的值
我了解到，GetOffsetShell用于获取主题分区的偏移量...
如何在Kubernetes上运行的Spring Boot应用程序上为Kafka Streams远程交互查询动态配置application.server
我们有一个运行着三个Pod的Kubernetes集群，我想知道...
Kafka Consumer的SeekToCurrentErrorHandler的Spring Xml配置
我正在将Kafka与我的一个应用程序集成。由于设计限制...
创建用于Kafka使用的ProtoBuf对象架构
我在Kafka上使用ProtoBuf。我们正在创建许多ProtoBu...
如何在TCP服务器上连接的每个物联网设备上执行特定服务？
我在TCP服务器上连接了100K的物联网设备。我必须根据...
System.ObjectDisposedException：句柄被破坏
Kafka使用者应用程序在启动停止使用者服务的过程时...
卡夫卡经纪人的工作原理，甚至使动物园管理员集群瘫痪 metadata.max.age.ms
我已经配置了三个Zookeeper节点集群，其中两个代理连...
Spring Kafka和Spring jdbc的事务管理
我有一个spring batch writer，它可以将数据发送到K...
如何在融合的Kafka中调试AvroConsumer？
我正在尝试从python读取Kafka，但收到的消息是None，...
使用websocket获取数据流时的主要问题是什么？
我是第一次做。使用websocket在哪里读取数据流。 这...
如果超过特定的字节数，是否可以丢弃聚合Kafka流？
我的目标是在超过一定数量的字节（序列化json）时将...
kafka-connect-http是否支持针对第二个URL的预身份验证？
我想使用现成的kafka连接器从REST API中获取数据。我...