apache-kafka专题提供apache-kafka的最新资讯内容,帮你更好的了解apache-kafka。
我试图按照Debezium博客<a href="https://debezium.io/blog/2017/09/25/streaming-to-another-database" rel="nofollow noreferrer">here</
我使用CopyOnWriteMap找到了kafka,但我不知道为什么不使用ConcurrentHashMap? ConcurrentHashMap的效率更高。 我发
我为消费者设置了这些属性 <pre><code>auto.commit.interval.ms=2000 max.poll.interval.ms=600000 max.poll.records=30 auto.off
我们正在迁移我们的kafka集群(创建新集群并迁移那里的所有主题,消费者,生产者)。我们在旧群集中
Am正在尝试将数据从一个流文件传输到另一文件。它运行得更早,突然提供了错误<code>ERROR Stopping due to e
我们在kafka中获得了Avro数据,其中的数据包含特殊字符,例如“FETäälö”。 我们正在尝试使用Spark
我在阅读多篇有关Kafka的文章,以了解有关消费者群体的知识。我有一个疑问,Kafka如何确保某个消费者
Confluent.Kafka AdminClient允许您创建一个主题,指定名称,分区数,复制因子和保留时间(我猜是通过configs
我们的服务利用Kafka发布和使用消息。我们使用蓝绿色部署策略来部署我们的服务。 考虑以下情形:
我有一个主题,假设名称为“ Test”。假设它有4个分区P1,P2,P3,P4。 现在,我正在发送一条消息,假
我创建了具有6个代理的集群,在kubernetes中具有代理选项<code>broker.rack</code>。这是我每个经纪人的机架配
我正在使用kafka kafka_2.11-0.11.0.2和融合版本3.3.0进行架构注册。 我已经定义了如下的avro模式: <pr
我正在寻找有关使用Spring Cloud Stream 3.x / Kafka活页夹实现的Kafka主题中有关重播消息策略的指南- <ol> <li
在Kafka中,每个使用者组均由许多使用者实例组成,以实现可伸缩性和容错能力。 kafka消费者可以
我正在研究一种情况,我想要写入的主题与写入的数据库表之间存在多对一的关系。数据源提供了有关
我在窗口上使用cygwin。 并在cygwin上执行以下命令以启动ksql服务器。 <pre><code>bash ksql-server-start .p
我是Kafka作为消息传递队列。如果我有一个保留策略为24小时且滞后时间很长的主题,是否有办法确定由
尝试以5分钟的滚动窗口汇总来自单个流的数据。最初,它运行良好,并且能够打印汇总记录。使用Java 8
版本:0.9 卡夫卡消费者在日志中抛出以下错误消息 <strong>“由于未知的成员ID,尝试加入组xxxxxxxxx
我有一个在多VM环境(私有云-具有我们自己的Kubernetes集群-4节点集群)中运行的Kafka代理。 我创建