我如何让Kafka根据提供的保留期限删除日志
我有一个kafka集群或3个在AWS EC2实例上运行的代理。...
使用插入脚本在Ignite缓存中插入数据时的关键是什么
<strong>能否请某人澄清我对Ignite缓存的疑问...
卡夫卡消息未插入数据库
Kafka消息未插入到postgresql数据库中。我可以在使...
汇流控制中心可扩展吗？
Confluent Control Center似乎是模块化的，但是我还...
运行单个Zookeeper实例安全吗？
运行单个Zookeeper实例安全吗？我有一台zookeeper服...
如何在Kafka中删除消费者组成员
是否可以从Kafka的消费者组中删除组成员，而不必删除...
考虑到在为长时间运行的处理添加新使用者时发生的重新平衡，我如何正确地暂停/恢复操作？
我正在将kafka 2.3.1（server）与spring-kafka 2.2....
如何在KSQLDB中的输出主题上构造嵌套的JSON消息
我从一个源系统收到了以下事件有效负载 为以下json有...
为大量的卡夫卡消费者提供持续的重新平衡
Confluent Platform版本5.4.2 在Kubernetes中部署...
如何将Flink连接到Druid？
我正在尝试将Flink连接到Druid。 但是，我不知道该怎...
使用SSIS将JSON Kafka消息消费到SQL Server表中
我们尝试将当前的Kafka Server集成到我们的SQL Serv...
Confluent.net中的模式匹配
因此，我有一种情况想与我所订阅主题的模式相匹配。...
卡夫卡经纪人指标是否包括集群中经纪人之间的消息率？
我正在使用Kafka中的JMX指标进行监视。 而且我发现&...
通过Kafka紧凑主题实现GDPR合规性
我想问您一些关于apache kafka和紧凑主题的问题。我...