我部署了 ksqlDB
kubernetes群集上的服务器(带有kafka群集,v2.4.0,已使用strimzi部署),部署文件如下:
apiVersion: v1
kind: Pod
metadata:
name: ksqldb-server
labels:
app: ksqldb-server
spec:
containers:
- name: ksqldb-server
# get latest version of image
image: confluentinc/ksqldb-cli:latest
imagePullPolicy: IfNotPresent
command: ["/bin/bash"]
args: ["-c","echo Waiting for Kafka to be ready... && \
cub kafka-ready -b my-kafka-brokers:9092 1 20 && \
echo Waiting a few seconds for topic creation to finish... && \
sleep 2 && \
/usr/bin/ksql-server-start /etc/ksqldb/ksql-server.properties"]
env:
- name: KSQL_CONFIG_DIR
value: "/etc/ksqldb"
- name: KSQL_OPTS
value: "-Dbootstrap.servers=my-kafka-brokers:9092 -Dksql.streams.auto.offset.reset=earliest"
- name: KSQL_LOG4J_OPTS
value: "-Dlog4j.configuration=file:/etc/ksqldb/log4j-rolling.properties"
ports:
# containerPort is the port exposed by the container (where ksql server is listening)
- containerPort: 8088
当我跑的时候 ksql
, ksql-cli
开始但我得到 Couldn't connect to the KSQL server: KSQL is not yet ready to serve requests
以及 Server Status: <unknown>
. 我无法成功执行任何语句( LIST TOPICS; CREATE STREAMS
ecc)。我在另一个kubernetes集群(kafka cluster v2.3.0)上部署了以前的配置,一切正常(我可以创建流、连接器和ecc)。以前部署的 ksql-server
v5.1.2会产生冲突吗?我用删除了这个豆荚 kubectl
之前 ksqlDB-server
部署。先谢谢你。
暂无答案!
目前还没有任何答案,快来回答吧!