小编mur*_*kas的帖子

如果第一经纪人破产,卡夫卡消费者将无法消费

我正在使用最新版本的kafka(kafka_2.12-1.0.0.tgz)。我设置了具有3个代理的简单集群(只是在每个实例的属性文件中更改了broker.id = 1和listeners = PLAINTEXT://:9092)。集群建立后,我使用以下命令创建了主题

./kafka-topics.sh --create    --zookeeper localhost:2181  --replication-factor 3     --partitions 13    --topic demo
Run Code Online (Sandbox Code Playgroud)

然后使用以下命令启动kafka消费者和生产者

./kafka-console-producer.sh --topic  demo  --broker-list localhost:9094,localhost:9093,localhost:9092

./kafka-console-consumer.sh --group test --bootstrap-server localhost:9094,localhost:9093,localhost:9092  --topic demo
Run Code Online (Sandbox Code Playgroud)

当所有经纪人都起来时,一切都很好。但是,如果我先杀死(按启动顺序),则将代理消息发送给代理,但使用者无法接收任何消息。消息不会丢失。启动后,该代理使用者将立即收到消息。

关闭代理实例后的使用者日志:

[2018-01-09 13:39:31,130]警告[Consumer clientId = consumer-1,groupId = test]无法建立到节点2147483646的连接。经纪人可能不可用。(org.apache.kafka.clients.NetworkClient)[2018-01-09 13:39:31,132]警告[Consumer clientId = consumer-1,groupId = test]无法建立到节点1的连接。经纪人可能不可用。(org.apache.kafka.clients.NetworkClient)[2018-01-09 13:39:31,344]警告[Consumer clientId = consumer-1,groupId = test]无法建立到节点2147483646的连接。经纪人可能不可用。(org.apache.kafka.clients.NetworkClient)[2018-01-09 13:39:31,451]警告[Consumer clientId = consumer-1,groupId = test]无法建立到节点1的连接。经纪人可能不可用。(org.apache.kafka.clients.NetworkClient)[2018-01-09 13:39:31,[848] WARN [Consumer clientId = consumer-1,groupId = test]无法建立到节点2147483646的连接。经纪人可能不可用。(org.apache.kafka.clients.NetworkClient)[2018-01-09 13:39:31,950]警告[Consumer clientId = consumer-1,groupId = test]无法建立到节点1的连接。经纪人可能不可用。(org.apache.kafka.clients.NetworkClient)[2018-01-09 13:39:32,363]警告[Consumer clientId = consumer-1,groupId = test]无法建立到节点2147483646的连接。经纪人可能不可用。(org.apache.kafka.clients.NetworkClient)[2018-01-09 13:39:33,092]警告[Consumer clientId = consumer-1,groupId = …

failover consumer apache-kafka

5
推荐指数
1
解决办法
3995
查看次数

Openshift (Origin) 使图像能够与 ROOT 用户一起运行

我正在尝试使用 openshift(使用 minishift)运行简单的 elk 容器。我试图运行的图像是这个麋鹿图像。在将映像部署到 openshift 期间,它会发出以下警告:

映像 sebp/elk 以 root 用户身份运行,这可能是您的集群管理员不允许的。

我忽略此错误并使用此映像创建部署。在该 pod 尝试启动容器后,但失败并显示以下错误:

启动定期命令调度程序 cron

cron:无法打开或创建/var/run/crond.pid:权限被拒绝...失败!

chown:更改“/var/lib/elasticsearch”的所有权:不允许操作

我认为这与 root 用户警告有关,然后尝试了这些步骤Enable Images to Run with USER in the Dockerfile and Grant a Service Account Access to the Privileged SCC 。他们都失败了,并出现以下错误:

Murats-MacBook-Pro-2:~ murat$ oc adm policy add-scc-to-group anyuid system:authenticated

来自服务器的错误(禁止):用户“系统”无法在集群范围内获取 securitycontextconstraints.security.openshift.io

Murats-MacBook-Pro-2:~ murat$ oc adm policy add-scc-to-user anyuid system:serviceaccount:elk:elk

来自服务器的错误(禁止):用户“系统”无法在集群范围内获取 securitycontextconstraints.security.openshift.io

非常感谢。

elasticsearch openshift docker minishift

3
推荐指数
1
解决办法
6089
查看次数