kafka

Java分布式学习之Kafka消息队列

Kafka是由Apache软件基金会开发的一个开源流处理平台，由Scala和Java编写。Kafka是一种高吞吐量的分布式发布订阅消息系统，它可以处理消费者在网站中的所有动作流数据

java Kafka生产者错误

我做了kafkajava生产者.但控制台说错误.kafka服务器在aws上.和制作人在我的Mac上.然而kara服务器是可以访问的.当我从制作人发送消息时,kafka服务器显示“已接受的连接…”

Laravel中Kafka的使用详解

这篇文章主要介绍了Laravel中Kafka的使用详解，kafka是一个分布式消息队列，具有高性能、持久化、多副本备份、横向扩展能力，有对于消息队列感兴趣的同学可以参考下

java – 我在哪里可以找到kafka的maven存储库？

我想尝试kafka0.8.但是我在哪里可以找到kafkamaven存储库.我应该添加哪些额外的存储库URL？我找到了一些博客但它不起作用.我正在寻找合适的maven依赖.或者我应该从git中检出它并部署在我们的内部神器中？

结合线程池实现apache kafka消费者组的误区及解决方法

这篇文章主要介绍了结合线程池实现apache kafka消费者组的误区及解决方法，本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下

我有一个不安全的kafka实例,有2个代理,一切运行正常,直到我决定为主题配置ACL,在ACL配置后,我的消费者停止从Kafka轮询数据,并且在获取具有相关ID的元数据时我不断收到警告错误,我的代理属性看起来像下面：-我的客户端配置如下所示：–我用下面的命令来配置ACL在我启动消费者后完成所有上述配置后,它停止接收消息.有人可以指出我在误解的地方.提前致谢.解决方法我们成功使用ACL,但没有使用P

java – kafka如何平衡分区加载？

我在kafka遇到了负载均衡的问题.所以,我创建了一个包含10个分区的主题并创建了2个消费者.这10个分区被划分并分配给这些消费者,并且工作正常.有时第一个消费者工作,有时第二.但是,在某一时刻,我们可能面临一种情况,例如第二个消费者收到消息并且需要时间来处理此消息.那么,我的问题是kafka将如何决定将消息存储在哪个分区中？

java – Kafka Connect实现错误

我在这里运行教程：http://kafka.apache.org/documentation.html#introduction当我进入“步骤7：使用KafkaConnect导入/导出数据”并尝试启动两个连接器时,我收到以下错误：这是教程的一部分：Next,we’llstarttwoconnectorsrunninginstandalonemode,whichmeanstheyruninasing

java – Kafka快速入门：我需要哪些依赖项？

接下来我该怎么办？我需要其他依赖项吗？解决方法问题是kafkabetawasbuiltinawaythatpomgeneratedwithajarisn’tvalidandmavencouldnotrecognizeitandparseproperly,从而获取传递依赖.我们已经设法通过在我们的pom定义中从该pom中获取所有依赖项来缓解此问题.我们正在等待kafka的下一个beta版本,其中将解决问题.完整依赖列表如下.请注意,您必须相应地更改scala版本依赖关系到kafka工件的后缀.至于Maybe

kafka

首页

kafka