请
登录后发表观点
so 2023-08-22 10:30:29显示这个:
Note: This will not show information about old Zookeeper-based consumers. Exception in thread "main" org.apache.kafka.common.config.ConfigException: Invalid url in bootstrap.servers: {ENV_KAFKA_ENDPOINTS:=127.0.0.1:9092} at org.apache.kafka.clients.ClientUtils.parseAndValidateAddresses(ClientUtils.java:51) at kafka.admin.AdminClient$.create(AdminClient.scala:527) at kafka.admin.AdminClient$.create(AdminClient.scala:516) at kafka.admin.AdminClient$.create(AdminClient.scala:514) at kafka.admin.ConsumerGroupCommand$KafkaConsumerGroupService.createAdminClient(ConsumerGroupCommand.scala:646) at kafka.admin.ConsumerGroupCommand$KafkaConsumerGroupService.<init>(ConsumerGroupCommand.scala:546) at kafka.admin.ConsumerGroupCommand$.main(ConsumerGroupCommand.scala:69) at kafka.admin.ConsumerGroupCommand.main(ConsumerGroupCommand.scala)
服务器资源多大
禹建勋(Team) 2023-08-22 10:12:43docker exec -it (docker ps | grep community | awk '{print $1}') bash -c '/usr/local/kafka/bin/kafka-consumer-groups.sh --bootstrap-server {ENV_KAFKA_ENDPOINTS:=127.0.0.1:9092} --describe --group md-workflow-consumer' 看下输出中 LAG 那一列有没有非 0 的
显示这个:
Note: This will not show information about old Zookeeper-based consumers.
Exception in thread "main" org.apache.kafka.common.config.ConfigException: Invalid url in bootstrap.servers: {ENV_KAFKA_ENDPOINTS:=127.0.0.1:9092}
at org.apache.kafka.clients.ClientUtils.parseAndValidateAddresses(ClientUtils.java:51)
at kafka.admin.AdminClient$.create(AdminClient.scala:527)
at kafka.admin.AdminClient$.create(AdminClient.scala:516)
at kafka.admin.AdminClient$.create(AdminClient.scala:514)
at kafka.admin.ConsumerGroupCommand$KafkaConsumerGroupService.createAdminClient(ConsumerGroupCommand.scala:646)
at kafka.admin.ConsumerGroupCommand$KafkaConsumerGroupService.<init>(ConsumerGroupCommand.scala:546)
at kafka.admin.ConsumerGroupCommand$.main(ConsumerGroupCommand.scala:69)
at kafka.admin.ConsumerGroupCommand.main(ConsumerGroupCommand.scala)
docker exec -it (docker ps | grep community | awk '{print $1}') bash -c '/usr/local/kafka/bin/kafka-consumer-groups.sh --bootstrap-server {ENV_KAFKA_ENDPOINTS:=127.0.0.1:9092} --describe --group md-workflow-consumer' 看下输出中 LAG 那一列有没有非 0 的