我正在尝试与Strimzi一起创建kafka-connect集群,并遇到以下错误
unable to recognize "kafka-connect.yaml": no matches for kind "KafkaConnect" in
version "kafka.strimzi.io/v1beta2"
这是卡夫卡连接,我有:
apiVersion: kafka.strimzi.io/v1beta2
kind: KafkaConnect
metadata:
name: kafka-connect
namespace: connect
我正在尝试使用这种方法将Kafka部署到Openshift:
部署设置好了,我可以在容器中设置一个代理和消费者,它们工作得很好。当我尝试使用控制台-消费者(使用端口转发到我的本地机器)访问一个主题时,我得到一条消息,告诉我代理不可用。
我尝试将advertised.listeners=PLAINTEXT://openshiftRoute:80覆盖添加到yaml文件,但现在我得到的是Error while fetching metadata with correlation id X : {test=LEADER_NOT_AVAILABLE}。
当我尝试使用到localhost的Openshif
我有一个kubernetes集群运行在多台本地(裸金属/物理)机器上。我想在集群上部署kafka,但我不知道如何在配置中使用strimzi。
我试着遵循快速入门页面上的教程:
我的动物园管理员吊舱正在2.4. Creating a cluster点等待:
Events:
Type Reason Age From Message
---- ------ ---- ---- -------
Warning FailedScheduling &
我有一个卡夫卡S3接收器连接器,我正在生产信息。但是,当我向主题发送消息时,我的接收器连接器的日志会抛出这个错误:
│ Invalid value io.confluent.connect.protobuf.ProtobufConverter for configuration value.converter: Class io.confluent.connect.protobuf.ProtobufConverter could not be found.
这是我的水槽
apiVersion: kafka.strimzi.io/v1beta2
kind: KafkaConnector
me
我对fabric8io 的使用有一个问题。
我想要的:在Kubernetes中用Strimzi运算符创建Kafka集群。如果我用CLI和kubectl完成了从到kubectl的所有步骤,这都很好。
但是,当我用kubernetes-client:5.2.1代码加载yaml资源时,会出现异常:
io.fabric8.kubernetes.client.KubernetesClientException: An error has occurred.
at io.fabric8.kubernetes.client.KubernetesClientException.launderThrowab
我尝试在之后,在docker-desktop k8s上运行strimzi。
我把所有的东西都安排好了。
$ kubectl get all -n my-kafka-project
NAME READY STATUS RESTARTS AGE
pod/my-cluster-entity-operator-7ddb6d5b88-q2xg8 3/3 Running 0 97m
p