我正在尝试让Kafka第一次在docker-compose上工作。该应用程序在没有docker的情况下运行良好。但是在docker上,出现如下所述的错误。卡夫卡为何会抛出此错误?
错误:
email-service_1 | 2018-12-01 14:32:02.448警告1 --- [ntainer#0-0-C-1] oakcNetworkClient:[Consumer clientId = consumer-2,groupId = kafka] 1个分区的领导者经纪人没有匹配的侦听器,包括[email-token-0]
我的docker-compose配置:
version: '3.3'
services:
zookeeper:
image: wurstmeister/zookeeper
ports:
- "2181:2181"
kafka:
image: wurstmeister/kafka
command: [start-kafka.sh]
environment:
KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
KAFKA_ADVERTISED_HOST_NAME: 192.168.23.134
KAFKA_CREATE_TOPICS: "email-token:1:1"
volumes:
- /var/run/docker.sock:/var/run/docker.sock
ports:
- "9092:9092"
depends_on:
- zookeeper
email-service:
build: ./email-service
environment:
SPRING_KAFKA_BOOTSTRAPSERVERS: kafka:9092
ports:
- "8081:8081"
depends_on:
- kafka
Run Code Online (Sandbox Code Playgroud) 如何在使用javafx时获取应用程序实例?
通常以这种方式启动应用程序:
public class LoginForm {
public static void main(String[] args) {
LoginApplication.launch(LoginApplication.class, args);
}
}
Run Code Online (Sandbox Code Playgroud)
方法启动不返回应用程序实例.有没有办法让我得到实例?
JVM参数noverify和Xverify之间有什么区别:none?
如果你有一个包含2个主要部分的for循环,就像这样:
for (object o : objects){
doSomething(o);
doSomething2(o);
}
Run Code Online (Sandbox Code Playgroud)
当你将这个循环分成2个这样的较小循环时,它会影响性能吗?
for (object o : objects){
doSomething(o);
}
for (object o : objects){
doSomething2(o);
}
Run Code Online (Sandbox Code Playgroud) 为什么Java有IINC字节码指令?已经有一个IADD字节码指令可以用来完成同样的任务。
那么为什么IINC存在呢?
java ×4
bytecode ×2
apache-kafka ×1
control-flow ×1
docker ×1
javafx ×1
loops ×1
spring-boot ×1