我正试着对Kafka的休息进行第二次审判。这是第一个的属性文件:
id=kafka-rest-test-server-1
schema.registry.url=http://localhost:8081,http://localhost:9081
zookeeper.connect=localhost:2181,localhost:2182,localhost:2183
bootstrap.servers=PLAINTEXT://localhost:9092,PLAINTEXT://localhost:9093,PLAINTEXT://localhost:9094
根据confluent的文件:
多个示例的唯一要求是为每个示例设置唯一的id。
但是,当我用其他 id
,将引发一个异常,指出该地址已在使用中:
WARN FAILED io.confluent.rest.Application$1@41294f8: java.net.BindException: Address already in use (org.eclipse.jetty.util.component.AbstractLifeCycle:212)
java.net.BindException: Address already in use
at sun.nio.ch.Net.bind0(Native Method)
at sun.nio.ch.Net.bind(Net.java:433)
at sun.nio.ch.Net.bind(Net.java:425)
at sun.nio.ch.ServerSocketChannelImpl.bind(ServerSocketChannelImpl.java:223)
at sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java:74)
...
1条答案
按热度按时间rqdpfwrv1#
id不能控制端口。“文档中的“多示例”是指独立的机器
就像模式注册表一样,配置
listeners
listeners
通过http或https侦听api请求的侦听器的逗号分隔列表默认值:“http://0.0.0.0:8082“
https://docs.confluent.io/current/kafka-rest/docs/config.html#kafkarest-配置
port
属性已被弃用,但如果您运行的是旧版本,也可以设置它例如,第一个示例,保留默认值
第二个例子,使用任何可用的端口
通常建议您使用多台计算机来实现高可用性和分布式处理。运行3个Zookeeper、3个经纪人、2个注册中心和2个代理,你基本上是在乞求内存用完