如何在创建kafka容器时修复crashLoopBackoff
在创建 Kafka 容器时修复 CrashLoopBackoff 的问题，可以采取以下步骤：
- 检查容器日志：首先，查看容器的日志，以了解 CrashLoopBackoff 的具体原因。可以使用以下命令获取容器的日志信息：
- 检查容器日志：首先，查看容器的日志，以了解 CrashLoopBackoff 的具体原因。可以使用以下命令获取容器的日志信息：
- 这将显示容器的日志输出，帮助确定问题所在。
- 检查资源限制：CrashLoopBackoff 可能是由于资源不足导致的。检查容器的资源限制，包括 CPU 和内存。确保为 Kafka 容器分配了足够的资源，以满足其运行需求。
- 检查配置文件：检查 Kafka 容器的配置文件，确保配置正确。特别关注 Kafka 的监听地址、端口和 ZooKeeper 连接信息等配置项。
- 检查网络连接：确保 Kafka 容器能够与所需的网络资源进行通信。检查容器的网络连接，包括网络策略、防火墙规则等，确保没有阻止 Kafka 容器与其他组件进行通信的限制。
- 检查存储卷：如果 Kafka 使用了存储卷进行数据持久化，检查存储卷的状态和权限设置。确保存储卷可正常访问，并且容器有足够的权限读写存储卷。
- 更新容器镜像：如果以上步骤都没有解决问题，尝试更新 Kafka 容器的镜像版本。有时，CrashLoopBackoff 可能是由于容器镜像本身的问题引起的。使用最新的稳定版本镜像可能有助于解决问题。
- 腾讯云相关产品推荐：腾讯云提供了一系列与容器相关的产品和服务，例如腾讯云容器服务（Tencent Kubernetes Engine，TKE）和腾讯云容器注册中心（Tencent Container Registry，TCR）。这些产品可以帮助您更轻松地管理和部署容器应用。您可以访问腾讯云官网了解更多详情。
请注意，以上步骤仅提供了一般性的解决方案，具体修复方法可能因环境和具体情况而异。在实际操作中，建议根据实际情况进行调试和排查，并参考相关文档和社区资源获取更多帮助。
相关·内容
我试图配置加密，身份验证和外部访问的合流卡夫卡在库伯内特斯。
舵图.
文件如下：
根据我已经配置的文档
secrets.yaml
Statefulset.yaml
当按照导出设置SSL时，KAFKA_ADVERTISED_LISTENERS=SSL://${POD_IP}:9092，外部://${HOST_IP}：$(31090+${KAFKA_BROKER_ID}) && \
豆荚得到了CrashLoopBackOff
我-汇合式-oss-cp- CrashLoopBackOff -0 2/3 CrashLoopBackOff 3 2 m40 my-con
浏览 0提问于2019-05-22得票数 0
回答已采纳
我创建了一个包含2个节点的kubernetes集群(GCP GKE)。我为druid (端口2181)设置了zookeeper，我工作得很好，但是，我想在同一个集群中部署kafka pod。所以我使用helm，但是当我在脚本values.yaml的末尾更改端口时，我运行helm upgrade，如下所示
helm升级kafka -n gke-k8s bitnami/kafka -f values_kafka.yaml
当我使用describe pod时，pod kafka zookeeper总是在端口2181上运行，即使我删除或重新创建它。同时，更新values.yaml后，kafka bro
浏览 30提问于2021-05-14得票数 0
回答已采纳
Kubernetes CrashLoopBackOff的默认值是什么？
我有个吊舱：
kubectl run mynginx --image nginx -- echo hello
我检查它的状况：
kubectl get pods -w
NAME READY STATUS RESTARTS AGE
mynginx 0/1 Pending 0 0s
mynginx 0/1 Pending 0 0s
mynginx 0/1 ContainerCreating 0 0s
m
浏览 14提问于2022-01-14得票数 0
回答已采纳
使用以下命令创建了一个pod
kubectl run bb --image=busybox --generator=run-pod/v1 --command -- sh -c "echo hi"
Pod正在重复创建
bb 1/1 Running 1 7s
bb 0/1 Completed 1 8s
bb 0/1 CrashLoopBackOff 1 9s
bb 0/1 Completed 2 22s
bb 0/1 CrashL
浏览 0提问于2019-08-30得票数 2
我创建了一个pod，它只计算pi和exit，它应该再次运行。在监视器上，我观察到状态是running，然后是completed，最后是crashloopbackoff。 我尝试了不同的图像，但问题是相同的。 apiVersion: v1
kind: Pod
metadata:
name: pi
spec:
containers:
- name: pi
image: perl
command: ["perl", "-Mbignum=bpi", "-wle", "print bpi(
浏览 3提问于2019-09-07得票数 1
我遇到了一个问题，当我尝试从目录部署CAM时，我的一些Pod在CrashLoopBackOff上。我还按照IBM文档中的说明从PV中清除数据(通过执行rm / -Rf / CAM _db/*)并清除以前安装的CAM。
以下是CrashLoopBackOff上的pods：
下面是我描述pod时的具体错误：
浏览 4提问于2018-10-24得票数 0
我正在创建一个带有一个init容器的复制控制器。但是，init容器无法启动，并且容器的状态是：
NAME READY STATUS RESTARTS AGE
testcontainer 0/1 CrashLoopBackOff 12 37m
我不知道到底是哪一部分失败了，日志也没有帮助。我的kubectl服务器版本是1.4 (与客户端版本不同)，因此我使用：
annotations:
pod.beta.kubernetes.io/init-containers:
浏览 0提问于2017-02-12得票数 10
2回答
我是卡夫卡的新手，我有点困惑。
到目前为止，我已经创建了两台带有以下命令的对接机器，一个是管理员，另一个是工作人员：
docker-machine create manager
docker-machine create worker1
我把这两个节点加在一个码头群里。
docker@manager:~$ docker node ls
浏览 6提问于2020-01-28得票数 0
回答已采纳
我有两个docker容器，我想让它们彼此可见。
1个容器:收集器(它收集站点上的页面视图并发送到kafka clucster)
2容器: kafka集群
我写了docker-compose文件：
version: "2"
services:
kafka-cluster:
image: landoop/fast-data-dev:cp3.3.0
environment:
ADV_HOST: 127.0.0.1
浏览 2提问于2020-03-17得票数 0
我正在尝试将我用于测试Kafka功能的被篡改的应用程序转换为一个Kubernetes部署文件。
用于执行按预期工作的容器的docker命令是：
docker run --name consumer-1 --network="host" -dt 56d57e1538d3 pizzaapp_multiconsumer1.py bash
但是，当将它转换到下面的Kubernetes部署文件并执行它时，我会在pods上得到一个CrashLoopBackOff错误。
spec:
hostNetwork: true
containers:
- name:
浏览 12提问于2021-06-16得票数 0
回答已采纳
我试图在我的Mac中安装install dev v0.1.2。
在我将事件流安装到我的Mac中之后，总是有几个程序无法运行。它包括三个kafka荚: es-ibm-es-kafka-sts-0/1/2，es-ibm-es-ui-部署-69758d9dfd-kc2zx，es-ibm-es-ui-oauth2-client-reg-pgvq6 6，还有一个名为es-ibm-es-ui-OAuth2-客户机-reg的失败作业。
您可以在以下图像中看到详细信息：
因此，我有两个关于ibm事件流的问题：
ibm事件流-dev是否仅支持ICP？如果没有ICP环境，我可以在本地
浏览 1提问于2018-08-31得票数 0
回答已采纳
1回答
我尝试设置使用init容器创建文件的pod。如果文件不存在，则应立即终止。这是我的yaml文件
apiVersion: v1
kind: Pod
metadata:
name: init-test-pod4
spec:
volumes:
- name: my-pvc
persistentVolumeClaim:
claimName: mypvc
containers:
- name: myapp-container
image: alpine
command: ['sh', '-c', 'if [
浏览 0提问于2020-05-31得票数 0
回答已采纳
我希望整理出一组精确的条件，来表明容器已经失败。
1)仅做好准备检查是不够的--容器可能处于初始化或容器创建状态，因此是健康的。
2)终止状态也是不够的--容器可能会作为滚动重启的一部分终止。此外，终止状态的原因是'string‘类型，所以可以是任何类型，我还没有找到一个详尽的列表。
3)等待状态也是不够的-它有同样的问题，原因是一个字符串，并且没有详尽的可能性列表。然而，检查"CrashLoopBackOff"，"ErrImagePull"，"ImagePullBackOff“确实给出了一个明确的答案，容器确实失败了。
如果这很重要，那么我的用
浏览 1提问于2018-08-30得票数 0
如何将Kafka部署在远程机器上的Kubernetes上？我已经成功地部署了动物园管理员舱，但卡夫卡荚不断崩溃(CrashLoopBackoff)。
下面是我正在使用的Kafka部署和服务yaml文件。对于文件中KAFKA_ADVERTISED_HOST_NAME的值，我也有混淆。
apiVersion: v1
kind: Service
metadata:
name: kafka-service
labels:
name: kafka
spec:
ports:
- port: 9092
name: kafka-port
protocol: TCP
浏览 3提问于2022-11-19得票数 -1
1回答
这是我的码头撰写文件：
version: "3.7"
services:
zookeeper:
image: 'bitnami/zookeeper:latest'
container_name: zookeeper
ports:
- 2181:2181
env_file:
- zookeeper.env
kafka:
image: 'bitnami/kafka:latest'
container_name: kafka
env_file:
浏览 4提问于2021-08-29得票数 2
回答已采纳
在卡夫卡重新启动后，春季启动的消费者微型服务无法向某个主题发送消息。
使用坞群配置，我安装了带有1个kafka broker和2个spring引导微服务(生产者和消费者)的单节点集群。我使用的是弹簧引导2.0.3
消费者和生产者(spring )在同一个覆盖网络“network”上，因此他们访问kafka的服务名为"kafka:9092“。
第一次发车一切都很顺利。
然后卡夫卡才重新开始，之后消费者就无法再发送来自卡夫卡主题的信息了。
由于docker-compose.yml (例如max_attempts: 3 => max_attempts: 4)中的小改动，
浏览 0提问于2019-05-08得票数 1
我使用的是JUnit5的卡夫卡测试容器。有人能让我知道如何在每次测试后从Kafka测试容器中删除数据，这样我就不必每次都销毁和重新创建kafka测试容器。
confluentinc/cp-kafka:5.2.1 测试容器版本- 1.6.2Docker Kafka图像名-
浏览 5提问于2022-05-29得票数 3
回答已采纳
1回答
我正在尝试创建一个Kafka生产者的java实例，它抛出了这个错误，但是当我运行控制台生产者时，它工作了。 我认为这个错误是由于导入 错误： [main] INFO org.apache.kafka.common.utils.AppInfoParser - Kafka version: 2.6.0
[main] INFO org.apache.kafka.common.utils.AppInfoParser - Kafka commitId: 62abe01bee039651
[main] INFO org.apache.kafka.common.utils.AppInfoParser -
浏览 12提问于2020-10-08得票数 0
回答已采纳
我正在尝试使用这个docker文件来声明kafka和zookeeper
version: '2'
services:
kafka:
image: landoop/fast-data-dev:cp3.3.0
hostname: kafka-host
ports:
- 29092:29092
- 3030:3030 # Landoop UI
- 8081-8083:8081-8083 # REST Proxy, Schema Registry, Kafka Conn
浏览 2提问于2018-10-27得票数 0
我正在9092端口的本地机器上运行Kafka服务器。我正在码头容器中运行一个服务，它使用docker，它需要向kafka服务器发送消息。
我试着用'localhost‘和IP写我的生产者的服务代码，但两者都不起作用。
有人能帮我解决这个问题吗？
浏览 1提问于2017-03-08得票数 24
回答已采纳
我正在使用3.3.1版本的confluent映像运行我的当前基础设施，一切都很好。现在，我正在尝试用v4.0.0设置一个沙箱环境，但我遇到了一些问题。
我遇到了问题，运行cp连接(v4.0.0)到由合流提供的坞映像。
基础设施细节:我使用的是码头映像cp:4.0.0以及动物园管理员和我所有的流/消费者/生产者应用程序，我在基础设施上的工作非常完美。只有cp连接:4.0.0不起作用。卡夫卡正在运行与自动主题创建活动。
我使用以下env变量运行连接容器：
-e CONNECT_BOOTSTRAP_SERVERS=kafka1.kafka:9092,kafka2.kafka:9092,kafka3.
浏览 5提问于2018-01-01得票数 0
我正在使用wurstmeister's docker-kafka项目在容器中运行kafka/zookeeper。我使用localhost作为KAFKA_ADVERTISED_HOST_NAME: localhost变量对容器进行停靠组合。 我已经编写了一个Java应用程序，它使用flink来连接和使用这个Kafka容器的一个主题。如果我导出一个可运行的jar并在我的机器上运行它，它会工作得非常好。当我创建以下镜像以从另一个docker容器运行jar时，我收到了一个异常(大约在执行30秒后) Exception in thread "main" org.apache.f
浏览 46提问于2019-06-13得票数 1
回答已采纳
我正在尝试使用kafka-python来访问Docker容器中的Kafka。我试图连接到Kafka的another化应用程序在同一网络中的另一个容器中。尝试初始化KafkaAdminClient对象时出现错误： self._kafka_admin = KafkaAdminClient(
bootstrap_servers=server,
api_version=(0, 10, 2),
api_version_auto_timeout_ms=120000
) 然后我得到了下一个错误： ? 这是配置文
浏览 688提问于2021-09-29得票数 0
我有一个部署到src/main/resources的jks文件。在我的global.xml中，我将密码设置为server_truststore.jks和path。当我部署到任意点时，我得到以下错误： 1 or more replicas in unexpected state: [Kubernetes] CrashLoopBackOff
- Resource server_truststore.jks could not be found 运行时: 4.3平台:运行时Fabric 在这一点上我不知道该怎么做。我想我无法配置我的TLS..。 global.xml代码片段： <kafka
浏览 31提问于2021-10-12得票数 0
2回答
我在虚拟机上安装了zookeeper和kafka docker容器。我的设置如下所示 zookeeper:
image: confluentinc/cp-zookeeper:latest
name:zookeeper
ZOOKEEPER_CLIENT_PORT: 2181
ports:
- "2181:2181"
kafka:
image: confluentinc/cp-kafka:latest
hostname: kafka
ports:
- "9092:9092"
- "29092:2
浏览 13提问于2020-02-29得票数 1
我们有kafka码头容器如下(在Linux 7.5上)
我们根据- 在容器上创建了kafka服务。
docker-compose ps
Name Command State Ports
-------------------------------------------------------------------------------------------------------------------
kafka-single-node_k
浏览 1提问于2019-11-05得票数 3
回答已采纳
我正在测试一个用以下命令创建的容器化kafka实例：
docker run -d --name kafkacontainer -p 9093:9093
-e KAFKA_BROKER_ID=1
-e KAFKA_TRANSACTION_STATE_LOG_MIN_ISR=1
-e KAFKA_TRANSACTION_STATE_LOG_REPLICATION_FACTOR=1
-e KAFKA_ZOOKEEPER_CONNECT=172.17.0.2:2181
-e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://mytestvm:9093,BROKER:
浏览 23提问于2022-11-15得票数 0
我的守则：
public static void Start()
{
tcpListener = new TcpListener(IPAddress.Any, 26950);
tcpListener.Start();
tcpListener.BeginAcceptTcpClient(TCPConnectCallback, null);
while(true){Thread.Sleep(500);}
}
private static void TCPConnectCallba
浏览 2提问于2021-03-18得票数 1
我想用ack模式MANUAL_IMMDEDIATE实现手动提交。我使用AcknowledgingMessageListener类作为消费者。它在应用程序运行时很好，但是在用户接收数据之后，应用程序就会出现错误，但是应用程序仍然在运行。只有在收到数据后才会发生错误。任何建议都将不胜感激，谢谢
import lombok.SneakyThrows;
import lombok.extern.slf4j.Slf4j;
import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.springframework.kafka.co
浏览 37提问于2022-06-07得票数 1
回答已采纳
我们在Docker容器中使用Kafka。当生产或消费消息时，如果主题不存在，我们会自动创建主题。我们想要3个主题分区，所以设置
num.partitions=3
在Kafka容器的/etc/kafka/server.properties文件中。但是，它不会生效。完成设置并重新启动容器后，尝试订阅或发布一些不存在的主题，主题将被创建，但只有一个分区。
我们在从image confluentinc/cp-kafka:5.1.0创建的容器和从image confluentinc/cp-enterprise-kafka:5.3.1创建的容器上进行了尝试，并且行为是相同的。
我们测试了使用命令创建主题：
浏览 2提问于2020-07-28得票数 0
我试着在kubenetes引擎上运行简单的python文件。当我收到下面的错误信息"Pod errors: CrashLoopBackOff“时。如何解决此问题？
浏览 49提问于2018-04-23得票数 0
回答已采纳
通常通过Java连接到Kafka，而不使用openfaas。(成功)
当openfaas服务调用时，连接到Kafka不起作用。
当运行openfaas创建的服务函数时，它不能连接到Kafka。(Kafka正在码头上运行)
docker-compose.yml :
version: '2'
services:
zookeeper:
container_name: zookeeper
image: confluentinc/cp-zookeeper:latest
environment:
ZOOKEEPER_CLIENT_PORT: 218
浏览 3提问于2022-02-02得票数 0
我正在开发一个使用spring-kafka的Kafka监听器的应用程序。我面临的问题是，当Kafka listener没有打开(各种原因，比如Kafka服务器没有打开或关闭)时，spring上下文初始化会失败。如何确保我的应用程序是独立的。
有谁能帮帮忙。
浏览 44提问于2017-09-10得票数 4
回答已采纳
我正在尝试在PostgreSQL上创建k8s荚。在吊舱部署之后，当我使用kubectl获取吊舱时，我看到了
NAME READY STATUS RESTARTS AGE
pgadmin 1/1 Running 5 9m
postgres 1/1 Running 5 8m
然而，当我运行kubectl -o时，我看到了这个输出
pgadmin 0/1
浏览 2提问于2022-11-15得票数 1
我正在使用文件创建展开。它创建了4个busybox pod的副本。一切都很好，直到这里。
但是，当我使用命令kubectl edit deployment my-dep2编辑此部署时，仅将busybox镜像的版本更改为1.31 (从K8s的角度来看，这是一个降级，但仍然是更新)，ReplicaSet并没有完全被替换。
kubectl get all --selector app=my-dep2 post编辑后的输出为：
NAME READY STATUS RESTARTS AGE
pod/my-dep2-55f6
浏览 36提问于2020-12-31得票数 1
1回答
我是第一次在码头工作，在这里我试图在码头容器上运行我的火花放电代码。这是我的项目结构。
我的Dockerfile内容：
from gcr.io/datamechanics/spark:platform-3.1-dm14
ENV PYSPARK_MAJOR_PYTHON_VERSION=3
WORKDIR /opt/application/
RUN wget https://jdbc.postgresql.org/download/postgresql-42.2.5.jar
RUN mv postgresql-42.2.5.jar /opt/spark/jars
COPY requ
浏览 8提问于2022-04-03得票数 0
我正在尝试使用kubernetes进行蓝绿色部署，我已经遵循了它，，这是可以的。我添加了一个活体探测器来执行健康检查，
apiVersion: extensions/v1beta1
kind: Deployment
metadata:
name: flask-1.3
spec:
replicas: 2
template:
metadata:
labels:
name: app
version: "1.3"
spec:
containers:
- name: appflask
浏览 2提问于2019-01-04得票数 6
在阅读了Dbt文档之后，我很难弄清楚如何在Windows 10上安装dbt核心(或任何其他软件包，如dbt、dbt-雪花等等)。
我已经安装了Desktop，已经运行了几个容器(主要是nodeJS容器和Kafka)。然而，我很难理解如何在我的Desktop控制台中提供这些新的Dbt容器。
我可以看到码头映像已正确安装。
$docker image ls
REPOSITORY TAG IMAGE ID CREATED SIZE
**ghcr.io/dbt-labs/dbt-core 1.2.1
浏览 11提问于2022-09-30得票数 0
我想用配置好的Kafka服务器运行“独立”Docker容器。我在卡夫卡网站()上了解了如何运行卡夫卡主题：)但是当我按照指示做所有事情时，我需要运行三个终端：
一个用于运行ZooKeeper服务器：
./bin/zookeeper-server-start.sh config/zookeeper.properties
第二，启动kafka服务器：
./bin/kafka-server-start.sh config/server.properties
第三，创建一个主题：
./bin/kafka-topics.sh --create --bootstrap-server localhost:
浏览 1提问于2019-12-29得票数 0
回答已采纳
1回答
我遵循了这个，当我试图在GKE上运行它时，我无法启动kafka pod。
它总是返回CrashLoopBackOff。我不知道如何显示pod错误日志。
这是我点击kubectl describe pod my-pod-xxx时的结果
Name: kafka-broker1-54cb95fb44-hlj5b
Namespace: default
Node: gke-xxx-default-pool-f9e313ed-zgcx/10.146.0.4
Start Time: Thu, 25 Oct 2018 11:40:21 +0900
La
浏览 1提问于2018-10-25得票数 0
Dockerfile
FROM ubuntu
MAINTAINER user@gmail.com
RUN apt-get update
RUN apt-get install -y openjdk-8-jdk
ADD build/libs/micro-service-gradle-0.0.1-SNAPSHOT.jar /var/local/
ENTRYPOINT exec java $JAVA_OPTS \
-jar /var/local/micro-service-gradle-0.0.1-SNAPSHOT.jar
EXPOSE 8080
deployment.yaml
apiVersio
浏览 2提问于2018-09-30得票数 3
1回答
我正在尝试设置一个本地kafka -连接堆栈与坞-撰写，我有一个问题，我的scala生产者，应该发送avro消息到一个卡夫卡主题使用模式注册表。
在我的生产者(scala)代码中，我执行以下操作：
val kafkaBootstrapServer = "kafka:9092"
val schemaRegistryUrl = "http://schema-registry:8081"
val topicName = "test"
val props = new Properties()
props.put("boots
浏览 4提问于2021-01-15得票数 0
回答已采纳
几周前，我的项目被更新为使用Kafka 3.2.1，而不是使用Spring 2.7.3 (3.1.1)附带的项目。我们进行这一升级是为了避免Kafka流中的一个问题--非法状态和参数异常不会在未被处理的异常处理程序中结束。在消费者方面，我们也转移到合作粘性分配。
同时，我们启动了一些弹性测试，并且开始出现使用Kafka批处理侦听器时不再在某些分区上使用的Kafka记录的问题。这个问题发生在测试引起的几次重新平衡之后(部署在Kubernetes中，我们停止了一些荚、微服务和代理实例)。这个问题不是每个听众都能听到的。卡夫卡的经纪人和微型服务已经开始运作。
在我们的调查中，
我们启用了assign
浏览 8提问于2022-09-01得票数 1
回答已采纳
我正在读取并尝试运行。如果移除sleep infinity，pod将会卡在CrashLoopBackOff中：
$ kubectl get po
NAME READY STATUS RESTARTS AGE
spark-master-715509916-zggtc 0/1 CrashLoopBackOff 5 3m
spark-worker-3468022965-xb5mw 0/1 Completed 5 3m
有
浏览 1提问于2017-06-16得票数 1
1回答
我正在Azure kubernetes服务上安装istio版本1.1.5。我遵循了这个istio站点中提到的安装过程。
我已经安装了istio演示安装包。安装成功后，很少有资源没有启动.
NAME READY STATUS RESTARTS AGE
grafana-6b849f66c8-hfn24 1/1 Running 0 10h
istio-citadel-6f958bff99-r4jdj
浏览 0提问于2019-05-20得票数 2
在我的应用程序中，我创建了一个生产者和一个消费者。
conf->set("dr_cb", delivery_cb, errstr);
conf->set("event_cb", event_cb, errstr);
RdKafka::Producer::create(conf.get(), errstr)
conf->set("log_level", "0", errstr);
conf->set("group.id", group_id, errstr);
conf->set(&
浏览 0提问于2018-05-12得票数 0
我目前正在从事一项监测服务，该服务将监测Kubernetes的部署及其吊舱。当部署没有运行预期数量的副本时，以及当pods容器意外地重新启动时，我希望通知用户。这可能不是正确的事情来监测，我将非常感谢一些反馈意见，我应该监测。
无论如何，主要的问题是豆荚的所有状态之间的差异。当我说状态时，我指的是运行kubectl get pods时的Status列。有关的情况如下：
- ContainerCreating
- ImagePullBackOff
- Pending
- CrashLoopBackOff
- Error
- Running
是什么导致吊舱/容器进入这些状态？
对于前四种状
浏览 0提问于2019-10-17得票数 6
1回答
在我的应用程序中，我使用的是Spring Kafka，并且有多个consumers在使用一个单独的topic。我想处理来自application.properties的application.properties属性。下面是我想添加的一些属性：
spring.kafka.consumer.group-id=test
spring.kafka.consumer.auto-offset-reset=latest
spring.kafka.consumer.key-deserializer=<Deserializer.class>
spring.kafka.consumer.value-
浏览 2提问于2022-09-29得票数 0
回答已采纳
pod.yml
apiVersion: v1
kind: Pod
metadata:
name: hello-pod
labels:
zone: prod
version: v1
spec:
containers:
- name: hello-ctr
image: hello-world:latest
ports:
- containerPort: 8080
kubectl create -f pod.yml
kubectl get pods
NAME READY STAT
浏览 1提问于2018-10-19得票数 1
回答已采纳
我有一个使用Kafka的Debezium设置。我可以像文档中描述的那样从kafka控制台消费消息。但是，当我在本地使用Python创建kafka消费者时，我无法消费消息。应该注意的是，kafka控制台工作得很好！
我尝试调查此问题，但无法获得类似的环境/情况
我要连接的python代码是：
from kafka import KafkaConsumer
consumer = KafkaConsumer('dbserver1.inventory.customers', group_id='my-group', bootstrap_servers=['loc
浏览 1提问于2019-04-29得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM活动推荐
腾讯云开发者
