我正在使用Kafka中的JMX指标进行监视。
而且我发现<code>kafka.server:type=BrokerTopicMetrics,name=MessagesInPerSec</code>
我想问您一些关于apache kafka和紧凑主题的问题。我们想提供一些关于Kafka压缩主题的PII数据。我们要通过
我正在以分发模式启动Kafka connect，但收到以下错误。
在其他开发集群上也可以正常工作，但是，只有在
我正在构建kafka指标的grafana仪表板。我的kafka版本是2.5.0
我对kafka.server：type = KafkaRequestHandlerPool，name = Re
我了解到，GetOffsetShell用于获取主题分区的偏移量。
t为-1表示最新消息，t为-2表示第一条消息。
我们有一个运行着三个Pod的Kubernetes集群，我想知道我们需要在<strong> application.server </strong>中提供什么RPC
我正在将Kafka与我的一个应用程序集成。由于设计限制，我只需要使用XML配置，而不要使用Spring注释和Spr
我在Kafka上使用ProtoBuf。我们正在创建许多ProtoBuf消息，但是我们只能使用这两个选项。想知道什么是最
我在TCP服务器上连接了100K的物联网设备。我必须根据设备ID选择要在每个设备上执行的特定服务。现在
Kafka使用者应用程序在启动停止使用者服务的过程时抛出ObjectDisposedException。我想了解是哪个进程破坏了
我已经配置了三个Zookeeper节点集群，其中两个代理连接到Zookeeper集群。
我创建了topic，以在发送消
我有一个spring batch writer，它可以将数据发送到Kafka并将值存储在数据库中
<pre><code>public class Writer impl
我正在尝试从python读取Kafka，但收到的消息是None，CLI中没有错误。
我正在使用通过腻子转发到目标主机
我是第一次做。使用websocket在哪里读取数据流。
这是我的代码段
RsvpApplication
<pre><code>@Spr
我的目标是在超过一定数量的字节（序列化json）时将聚合设置为<code>null</code>。有什么方法还是保留时
我想使用现成的kafka连接器从REST API中获取数据。我在汇合的集线器上找到kafka-connect-http连接器，但该连
在AWS Fargate中使用Debezium postgresql源连接器运行confluentinc / cp-kafka-connect：5.5.1。
在第一次运行时，没
我正在构建一个Spring Kafka Consumer应用程序，该应用程序使用来自Kafka Topic的消息并执行数据库任务。每天
我对整个微服务体系结构还很陌生，所以我一直在使用Kafka来检索数据以及向微服务发送数据。我知道如
我想在此处添加一些代码，并从Flink中输出protobuf数据。
我正在使用Flink的Apache Kafka连接器，以便将
