我正在使用最新版本的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 = …
我正在尝试使用 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
非常感谢。