Client exception: Could not create subscriber group / A subscriber closed unexpectedly


#1

Hey guys.

During todays development session I re-connected pretty often to my Zeebe broker on my Windows 10 laptop. After a while I got his exception every time I tried to connect - I have no idea what caused it. I restarted the broker and it was gone. Any ideas?

Cheers
Bernd

org.springframework.context.ApplicationContextException: Failed to start bean 'springZeebeClient'; nested exception is io.zeebe.client.cmd.ClientException: Could not open subscription: io.zeebe.client.cmd.ClientException: Could not create subscriber group [topic=default-topic, taskHandler=io.zeebe.spring.client.config.processor.TaskHandlerPostProcessor$$Lambda$73/426123784@74ff0ea6, taskType=ship-goods, lockTime=300000, lockOwner=worker-name, capacity=32]: A subscriber closed unexpectedly.
	at org.springframework.context.support.DefaultLifecycleProcessor.doStart(DefaultLifecycleProcessor.java:178) ~[spring-context-4.3.7.RELEASE.jar:4.3.7.RELEASE]
	at org.springframework.context.support.DefaultLifecycleProcessor.access$200(DefaultLifecycleProcessor.java:50) ~[spring-context-4.3.7.RELEASE.jar:4.3.7.RELEASE]
	at org.springframework.context.support.DefaultLifecycleProcessor$LifecycleGroup.start(DefaultLifecycleProcessor.java:348) ~[spring-context-4.3.7.RELEASE.jar:4.3.7.RELEASE]
	at org.springframework.context.support.DefaultLifecycleProcessor.startBeans(DefaultLifecycleProcessor.java:151) ~[spring-context-4.3.7.RELEASE.jar:4.3.7.RELEASE]
	at org.springframework.context.support.DefaultLifecycleProcessor.onRefresh(DefaultLifecycleProcessor.java:114) ~[spring-context-4.3.7.RELEASE.jar:4.3.7.RELEASE]
	at org.springframework.context.support.AbstractApplicationContext.finishRefresh(AbstractApplicationContext.java:879) ~[spring-context-4.3.7.RELEASE.jar:4.3.7.RELEASE]
	at org.springframework.boot.context.embedded.EmbeddedWebApplicationContext.finishRefresh(EmbeddedWebApplicationContext.java:144) ~[spring-boot-1.5.2.RELEASE.jar:1.5.2.RELEASE]
	at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:545) ~[spring-context-4.3.7.RELEASE.jar:4.3.7.RELEASE]
	at org.springframework.boot.context.embedded.EmbeddedWebApplicationContext.refresh(EmbeddedWebApplicationContext.java:122) ~[spring-boot-1.5.2.RELEASE.jar:1.5.2.RELEASE]
	at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:737) [spring-boot-1.5.2.RELEASE.jar:1.5.2.RELEASE]
	at org.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:370) [spring-boot-1.5.2.RELEASE.jar:1.5.2.RELEASE]
	at org.springframework.boot.SpringApplication.run(SpringApplication.java:314) [spring-boot-1.5.2.RELEASE.jar:1.5.2.RELEASE]
	at org.springframework.boot.SpringApplication.run(SpringApplication.java:1162) [spring-boot-1.5.2.RELEASE.jar:1.5.2.RELEASE]
	at org.springframework.boot.SpringApplication.run(SpringApplication.java:1151) [spring-boot-1.5.2.RELEASE.jar:1.5.2.RELEASE]
	at io.flowing.retail.kafka.order.OrderApplication.main(OrderApplication.java:15) [classes/:na]
Caused by: io.zeebe.client.cmd.ClientException: Could not open subscription: io.zeebe.client.cmd.ClientException: Could not create subscriber group [topic=default-topic, taskHandler=io.zeebe.spring.client.config.processor.TaskHandlerPostProcessor$$Lambda$73/426123784@74ff0ea6, taskType=ship-goods, lockTime=300000, lockOwner=worker-name, capacity=32]: A subscriber closed unexpectedly.
	at io.zeebe.client.task.impl.subscription.EventSubscriberGroup.open(EventSubscriberGroup.java:417) ~[zeebe-client-java-0.7.0.jar:0.7.0]
	at io.zeebe.client.task.impl.subscription.TaskSubscriptionBuilderImpl.open(TaskSubscriptionBuilderImpl.java:92) ~[zeebe-client-java-0.7.0.jar:0.7.0]
	at io.zeebe.spring.client.config.processor.TaskHandlerPostProcessor.lambda$null$2(TaskHandlerPostProcessor.java:58) ~[spring-zeebe-0.2.0.jar:0.2.0]
	at java.util.ArrayList.forEach(Unknown Source) ~[na:1.8.0_131]
	at io.zeebe.spring.client.config.processor.TaskHandlerPostProcessor.lambda$apply$3(TaskHandlerPostProcessor.java:51) ~[spring-zeebe-0.2.0.jar:0.2.0]
	at io.zeebe.spring.client.config.SpringZeebeClient.lambda$start$0(SpringZeebeClient.java:67) ~[spring-zeebe-0.2.0.jar:0.2.0]
	at java.lang.Iterable.forEach(Unknown Source) ~[na:1.8.0_131]
	at io.zeebe.spring.client.config.SpringZeebeClient.start(SpringZeebeClient.java:67) ~[spring-zeebe-0.2.0.jar:0.2.0]
	at org.springframework.context.support.DefaultLifecycleProcessor.doStart(DefaultLifecycleProcessor.java:175) ~[spring-context-4.3.7.RELEASE.jar:4.3.7.RELEASE]
	... 14 common frames omitted
Caused by: java.util.concurrent.ExecutionException: io.zeebe.client.cmd.ClientException: Could not create subscriber group [topic=default-topic, taskHandler=io.zeebe.spring.client.config.processor.TaskHandlerPostProcessor$$Lambda$73/426123784@74ff0ea6, taskType=ship-goods, lockTime=300000, lockOwner=worker-name, capacity=32]: A subscriber closed unexpectedly.
	at java.util.concurrent.CompletableFuture.reportGet(Unknown Source) ~[na:1.8.0_131]
	at java.util.concurrent.CompletableFuture.get(Unknown Source) ~[na:1.8.0_131]
	at io.zeebe.client.task.impl.subscription.EventSubscriberGroup.open(EventSubscriberGroup.java:413) ~[zeebe-client-java-0.7.0.jar:0.7.0]
	... 22 common frames omitted
Caused by: io.zeebe.client.cmd.ClientException: Could not create subscriber group [topic=default-topic, taskHandler=io.zeebe.spring.client.config.processor.TaskHandlerPostProcessor$$Lambda$73/426123784@74ff0ea6, taskType=ship-goods, lockTime=300000, lockOwner=worker-name, capacity=32]: A subscriber closed unexpectedly.
	at io.zeebe.client.task.impl.subscription.EventSubscriberGroup$ClosedState.work(EventSubscriberGroup.java:340) ~[zeebe-client-java-0.7.0.jar:0.7.0]
	at io.zeebe.client.task.impl.subscription.EventSubscriberGroup$ClosedState.work(EventSubscriberGroup.java:331) ~[zeebe-client-java-0.7.0.jar:0.7.0]
	at io.zeebe.util.state.WaitState.doWork(WaitState.java:25) ~[zb-util-0.7.0.jar:0.7.0]
	at io.zeebe.util.state.StateMachine.doWork(StateMachine.java:124) ~[zb-util-0.7.0.jar:0.7.0]
	at io.zeebe.util.state.StateMachineAgent.doWork(StateMachineAgent.java:53) ~[zb-util-0.7.0.jar:0.7.0]
	at io.zeebe.client.task.impl.subscription.EventSubscriberGroup.maintainState(EventSubscriberGroup.java:457) ~[zeebe-client-java-0.7.0.jar:0.7.0]
	at io.zeebe.client.task.impl.subscription.EventSubscribers.lambda$maintainState$3(EventSubscribers.java:156) ~[zeebe-client-java-0.7.0.jar:0.7.0]
	at io.zeebe.client.task.impl.subscription.EventSubscribers.forAllDo(EventSubscribers.java:167) ~[zeebe-client-java-0.7.0.jar:0.7.0]
	at io.zeebe.client.task.impl.subscription.EventSubscribers.maintainState(EventSubscribers.java:156) ~[zeebe-client-java-0.7.0.jar:0.7.0]
	at io.zeebe.client.task.impl.subscription.EventAcquisition.doWork(EventAcquisition.java:53) ~[zeebe-client-java-0.7.0.jar:0.7.0]
	at io.zeebe.util.actor.ActorRunner.tryRunActor(ActorRunner.java:180) ~[zb-util-0.7.0.jar:0.7.0]
	at io.zeebe.util.actor.ActorRunner.runActor(ActorRunner.java:160) ~[zb-util-0.7.0.jar:0.7.0]
	at io.zeebe.util.actor.ActorRunner.doWork(ActorRunner.java:129) ~[zb-util-0.7.0.jar:0.7.0]
	at io.zeebe.util.actor.ActorRunner.doWorkUntilClose(ActorRunner.java:86) ~[zb-util-0.7.0.jar:0.7.0]
	at io.zeebe.util.LogUtil.doWithMDC(LogUtil.java:34) ~[zb-util-0.7.0.jar:0.7.0]
	at io.zeebe.util.actor.ActorRunner.run(ActorRunner.java:77) ~[zb-util-0.7.0.jar:0.7.0]
	at java.lang.Thread.run(Unknown Source) ~[na:1.8.0_131]

#2

We rewrote the client’s subscriber implementation on current master, so I would say let’s see if this occurs again with the next release and only then spend time trying to understand it. Is that ok for you?


#3

OK (+ some charachters to be able to post the OK :-))