Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
如何将 Kafka 承诺的消费者偏移量更改为所需的偏移量
我有卡夫卡流应用程序 我的应用程序正在成功处理事件 如何使用所需的偏移量更改 Kafka 提交的消费者偏移量以重新处理 跳过事件 我试过如何更改主题的起始偏移量 https stackoverflow com questions 29791
ApacheKafka
apachezookeeper
kafkaconsumerapi
apachekafkastreams
我可以在Zookeeper中递归创建路径吗?
我拉着动物园管理员 http hadoop apache org zookeeper 进入一个用于并发管理的项目 我尝试的第一件事对我来说是非常明显的 使用 zkpython 绑定 zh zookeeper init localhost 2
python
apachezookeeper
处理时出现用户级 KeeperException
我知道这已经是之前问过 https stackoverflow com questions 30495057 zookeeper having keeperexception but kafka able to create topics
ApacheKafka
apachezookeeper
如何以编程方式检测 ensemble 客户端中的哪个服务器连接到?
如何以编程方式检测客户端连接到 ZooKeeper 集合中的哪台服务器 我正在使用阿帕奇策展人 http curator apache org API 和我正在通过注册监听连接状态变化连接状态监听器 https curator apache
apachezookeeper
apachecurator
删除zookeeper中的kafka消费者组
我正在使用 kafka 2 9 2 0 8 1 1 和 Zookeeper 3 4 6 是否有一个实用程序可以自动从zookeeper中删除消费者组 或者我可以删除 Zookeeper 中 consumers group id 下的所有内容
apachezookeeper
ApacheKafka
如何将消息发送到Kafka中的特定分区?
我创建了一个有很多分区的主题 使用控制台生产者 我想将消息发送到特定分区并通过控制台消费者查看 在控制台制作人上我尝试过这个 kafka console producer bat broker list localhost 9092 top
ApacheKafka
apachezookeeper
kafkaproducerapi
kafka作为微服务中的消息总线可靠吗
我使用 kafka 作为微服务架构的消息总线 因此多个服务监听一个主题的消息 因此 服务的上线高度依赖于主题 但是 有很多情况我得到leader not available broker not available and leader 1
ApacheKafka
apachezookeeper
microservices
如何获取 apache kafka 中的所有主题?
RequestMapping value getTopics method RequestMethod GET ResponseBody public Response getAllTopics ZkClient zkClient new
Java
ApacheKafka
apachezookeeper
Solr 和 Zookeeper 配置
在生产环境中 是否应该在每台可能的服务器上设置 Solr 包括具有 Zookeeper 的服务器 谈论外部Zookeeper 服务器总数 5 情况1 所有 5 台服务器上都有 Solr Zookeeper 在 3 台服务器上 案例2 Sol
Solr
apachezookeeper
Zookeeper/SASL 校验和失败
如何修复生成此错误的问题 WARN NIOServerCxn Factory 0 0 0 0 0 0 0 0 2181 ZooKeeperServer 1040 Client failed to SASL authenticate java
apachezookeeper
kerberos
sasl
Zookeeper 的临时 znode 的用例是什么?
Zookeeper 文档内容如下 ZooKeeper 也有临时节点的概念 只要创建 znode 的会话处于活动状态 这些 znode 就会存在 当会话结束时 znode 将被删除 当您想要实现 待定 时 临时节点非常有用 我了解其功能 但是
apachezookeeper
使用 Zookeeper 而不仅仅是数据库来管理分布式系统的目的是什么?
我正在学习Zookeeper 到目前为止我不明白将其用于数据库无法解决的分布式系统的目的 我读过的用例是通过让 Zookeeper 客户端读 写 Zookeeper 服务器来为分布式系统实现锁 屏障等 不能通过读 写数据库来实现同样的目的
Java
apachezookeeper
distributedcomputing
在 Jetty 中嵌入 Apache ZooKeeper 生成调试日志消息
我正在使用 Jetty 8 和 ZooKeeper 3 4 5 当我连接到 ZooKeeper 时 jetty 不断生成 DEBUG 级别消息 怎么抑制呢 16 54 56 757 main SendThread 127 0 0 1 218
Log4j
Jetty
apachezookeeper
启动 Zookeeper 集群。错误:无法找到或加载主类 org.apache.zookeeper.server.quorum.QuorumPeerMain
我在 CentOS 5 8 上运行 我一直遵循这个方向集群 多服务器 Zookeeper 设置 http zookeeper apache org doc r3 3 3 zookeeperAdmin html sc zkMulitServe
apache
clustercomputing
apachezookeeper
无法从客户端会话 ID 读取附加数据
我们有hadoop集群3 kafka机器和3 动物园管理员 servers hadoop 版本 2 6 4 HORTONWORKS 在zookeeper日志下 var log zookeeper 我们看到了一百万条警告消息 例如 2019
ApacheKafka
apachezookeeper
hdp
在Kafka集群中添加新的ZooKeeper节点?
我正在运行一个包含五个节点的 Apache Kafka 集群 并且正在使用一个包含三个节点的 Apache ZooKeeper 集群 在zookeeper properties文件中 server 1 zNode01 2888 3888 s
ApacheKafka
apachezookeeper
从 Kafka 消费失败迭代器处于失败状态
我在使用来自 kafka 的消息时遇到异常 org springframework messaging MessagingException Consuming from Kafka failed nested exception is j
将 Zookeeper 与 Solr 结合使用,但只有 2 台服务器
我是 Solr 的新手 正在尝试 SolrCloud 看来 ZooKeeper 是管理高可用性的最佳方式 然而 在我们的生产环境中 我们只有两台服务器 主动 主动 我担心 Zookeeper 在两台服务器上并不理想 因为如果其中任何一个出现
Solr
apachezookeeper
奇怪的DNS服务器导致Hadoop和HBase出现故障
我的网络有一些奇怪的 据我所知 DNS 服务器 这会导致 Hadoop 或 HBase 出现故障 它将我的主机名解析为我的机器不知道的某个地址 即没有这样的接口 如果 etc hosts 中有以下条目 Hadoop 确实可以工作 127 0
Hadoop
DNS
Hbase
apachezookeeper
Zookeeper:无法写入 PID
所以我正在尝试开始使用 Accumulo 我安装了 Hadoop 它运行时没有问题 但是当我尝试启动 Zookeeper 时 我得到 JMX enabled by default Using config opt zookeeper bin
apachezookeeper
«
1
2
3
4
5
»