由自定义按钮触发的子流程，一直显示排队中的状态，请问如何让它恢复正常运行？

so Lv.2入道发布于 2023-08-21 17:35 最后回复 2023-08-22 10:35:23 分享

3 回复787 浏览

WX20230821-172959@2x.png

禹建勋 Lv.6传道明道云员工 2023-08-22 10:35:23

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)
显示这个：
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)

服务器资源多大

so Lv.2入道 2023-08-22 10:30:29

禹建勋 2023-08-22 10:12:43

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 的

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 的

显示这个：

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)

禹建勋 Lv.6传道明道云员工 2023-08-22 10:12:43

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 的

so Lv.2入道

积分
25
注册排名
744