如何运行Kafkarest的两个示例

2vuwiymt  于 2021-06-08  发布在  Kafka
关注(0)|答案(1)|浏览(508)

我正试着对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)

...
rqdpfwrv

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 属性已被弃用,但如果您运行的是旧版本,也可以设置它
例如,第一个示例,保留默认值
第二个例子,使用任何可用的端口

listeners=http://0.0.0.0:18082

通常建议您使用多台计算机来实现高可用性和分布式处理。运行3个Zookeeper、3个经纪人、2个注册中心和2个代理,你基本上是在乞求内存用完

相关问题