Send message to Kafka Topic timeout from kie-server

49 views

Skip to first unread message

Pankaj Kumar

unread,

May 27, 2024, 2:26:22 AM5/27/24

to jBPM Usage

Hello,

I am running drools-wb and kie-server in docker container version 7.61.0.Final(business central). I have kafka running in another container with port mapped to 9092 to host.

I have followed doc https://access.redhat.com/documentation/en-us/red_hat_process_automation_manager/7.10/html/integrating_red_hat_process_automation_manager_with_other_products_and_components/kieserver-kafka-emit-proc_integrating-amq-streams.

I have added Custom Task to produce message(bootrstrap server: docker.for.mac.localhost:9092) to kafka topic and used in BPMN. I have added jbpm-event-emitters-kafka jar in kie server and added following properties as well.

<system-properties>

</system-properties>

After Deployment of project in kie-server and start the processing getting following log

06:01:45,549 INFO [org.drools.compiler.kie.builder.impl.InternalKieModuleProvider] (default task-1) Creating KieModule for artifact com.autobahn:rules:1.0.0-SNAPSHOT

06:01:45,553 INFO [org.drools.modelcompiler.CanonicalKieModuleProvider] (default task-1) No executable model found for artifact com.autobahn:rules:1.0.0-SNAPSHOT. Falling back to resources parsing.

06:01:45,910 INFO [stdout] (default task-1) km is - org.drools.compiler.kie.builder.impl.ZipKieModule

06:01:45,918 INFO [stdout] (default task-1) zkm - [META-INF/maven/com.autobahn/rules/pom.properties, META-INF/maven/com.autobahn/rules/pom.xml, META-INF/kmodule.info, META-INF/persistence.xml, META-INF/kmodule.xml, META-INF/kie-deployment-descriptor.xml, META-INF/defaultKieBase/kbase.cache, com/autobahn/rules/Task-taskform.frm, com/autobahn/rules/EncapsulatingPojo.class, com/autobahn/rules/telemetry.drl, com/autobahn/rules/ReadKjar.class, com/autobahn/rules/read_drl.process-taskform.frm, com/autobahn/rules/read_drl.process-svg.svg, com/autobahn/rules/process.bpmn]

06:01:45,922 INFO [org.apache.kafka.clients.producer.ProducerConfig] (default task-1) ProducerConfig values:

acks = 1

batch.size = 16384

bootstrap.servers = [docker.for.mac.localhost:9092]

buffer.memory = 33554432

client.dns.lookup = use_all_dns_ips

client.id = producer-2

compression.type = none

connections.max.idle.ms = 540000

delivery.timeout.ms = 120000

enable.idempotence = false

interceptor.classes = []

internal.auto.downgrade.txn.commit = false

key.serializer = class org.apache.kafka.common.serialization.StringSerializer

linger.ms = 0

max.block.ms = 60000

max.in.flight.requests.per.connection = 5

max.request.size = 1048576

metadata.max.age.ms = 300000

metadata.max.idle.ms = 300000

metric.reporters = []

metrics.num.samples = 2

metrics.recording.level = INFO

metrics.sample.window.ms = 30000

partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner

receive.buffer.bytes = 32768

reconnect.backoff.max.ms = 1000

reconnect.backoff.ms = 50

request.timeout.ms = 30000

retries = 2147483647

retry.backoff.ms = 100

sasl.client.callback.handler.class = null

sasl.jaas.config = null

sasl.kerberos.kinit.cmd = /usr/bin/kinit

sasl.kerberos.min.time.before.relogin = 60000

sasl.kerberos.service.name = null

sasl.kerberos.ticket.renew.jitter = 0.05

sasl.kerberos.ticket.renew.window.factor = 0.8

sasl.login.callback.handler.class = null

sasl.login.class = null

sasl.login.refresh.buffer.seconds = 300

sasl.login.refresh.min.period.seconds = 60

sasl.login.refresh.window.factor = 0.8

sasl.login.refresh.window.jitter = 0.05

sasl.mechanism = GSSAPI

security.protocol = PLAINTEXT

security.providers = null

send.buffer.bytes = 131072

socket.connection.setup.timeout.max.ms = 30000

socket.connection.setup.timeout.ms = 10000

ssl.cipher.suites = null

ssl.enabled.protocols = [TLSv1.2, TLSv1.3]

ssl.endpoint.identification.algorithm = https

ssl.engine.factory.class = null

ssl.key.password = null

ssl.keymanager.algorithm = SunX509

ssl.keystore.certificate.chain = null

ssl.keystore.key = null

ssl.keystore.location = null

ssl.keystore.password = null

ssl.keystore.type = JKS

ssl.protocol = TLSv1.3

ssl.provider = null

ssl.secure.random.implementation = null

ssl.trustmanager.algorithm = PKIX

ssl.truststore.certificates = null

ssl.truststore.location = null

ssl.truststore.password = null

ssl.truststore.type = JKS

transaction.timeout.ms = 60000

transactional.id = null

value.serializer = class org.apache.kafka.common.serialization.StringSerializer

06:01:45,957 WARN [org.apache.kafka.clients.producer.ProducerConfig] (default task-1) The configuration 'broker.list' was supplied but isn't a known config.

06:01:45,958 WARN [org.apache.kafka.clients.producer.ProducerConfig] (default task-1) The configuration 'producer.type' was supplied but isn't a known config.

06:01:45,958 WARN [org.apache.kafka.clients.producer.ProducerConfig] (default task-1) The configuration 'compression.codec' was supplied but isn't a known config.

06:01:45,959 WARN [org.apache.kafka.clients.producer.ProducerConfig] (default task-1) The configuration 'serializer.class' was supplied but isn't a known config.

06:01:45,959 INFO [org.apache.kafka.common.utils.AppInfoParser] (default task-1) Kafka version: 2.8.0

06:01:45,959 INFO [org.apache.kafka.common.utils.AppInfoParser] (default task-1) Kafka commitId: ebb1d6e21cc92130

06:01:45,960 INFO [org.apache.kafka.common.utils.AppInfoParser] (default task-1) Kafka startTimeMs: 1716789705959

06:01:46,015 INFO [org.apache.kafka.clients.Metadata] (kafka-producer-network-thread | producer-2) [Producer clientId=producer-2] Cluster ID: Some(5L6g3nShT-eMCtK--X86sw)

06:01:46,026 INFO [stdout] (default task-1) Data pushed to topic: rule-events

06:01:46,027 INFO [org.apache.kafka.clients.producer.KafkaProducer] (default task-1) [Producer clientId=producer-2] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms.

06:01:46,034 WARN [org.apache.kafka.clients.NetworkClient] (kafka-producer-network-thread | producer-2) [Producer clientId=producer-2] Connection to node 1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.

06:01:46,061 WARN [org.apache.kafka.clients.NetworkClient] (kafka-producer-network-thread | autobahn-rules) [Producer clientId=autobahn-rules] Connection to node 1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.

06:01:46,087 WARN [org.apache.kafka.clients.NetworkClient] (kafka-producer-network-thread | producer-2) [Producer clientId=producer-2] Connection to node 1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.

we can see config has right kafka bootstrap server but getting warning logs to connect to localhost:9092 and then broke with error.

6:07:05,314 ERROR [org.kie.server.remote.rest.jbpm.UserTaskResource] (default task-1) Unexpected error during processing [read_drl.process:1 - KafkaPublishMessages:2] -- java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.TimeoutException: Topic rule-events not present in metadata after 60000 ms.: org.jbpm.workflow.instance.WorkflowRuntimeException: [read_drl.process:1 - KafkaPublishMessages:2] -- java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.TimeoutException: Topic rule-events not present in metadata after 60000 ms.
at deployment.kie-server.war//org.jbpm.workflow.instance.node.WorkItemNodeInstance.processWorkItemHandler(WorkItemNodeInstance.java:170)
at deployment.kie-server.war//org.jbpm.workflow.instance.node.WorkItemNodeInstance.internalTrigger(WorkItemNodeInstance.java:141)
at deployment.kie-server.war//org.jbpm.workflow.instance.impl.NodeInstanceImpl.trigger(NodeInstanceImpl.java:207)
at deployment.kie-server.war//org.jbpm.workflow.instance.impl.NodeInstanceImpl.triggerNodeInstance(NodeInstanceImpl.java:415)
at deployment.kie-server.war//org.jbpm.workflow.instance.impl.NodeInstanceImpl.triggerNodeInstance(NodeInstanceImpl.java:393)
at deployment.kie-server.war//org.jbpm.workflow.instance.impl.NodeInstanceImpl.triggerCompleted(NodeInstanceImpl.java:362)
at deployment.kie-server.war//org.jbpm.workflow.instance.impl.ExtendedNodeInstanceImpl.triggerCompleted(ExtendedNodeInstanceImpl.java:59)
at deployment.kie-server.war//org.jbpm.workflow.instance.node.StateBasedNodeInstance.triggerCompleted(StateBasedNodeInstance.java:413)
at deployment.kie-server.war//org.jbpm.workflow.instance.node.StateBasedNodeInstance.triggerCompleted(StateBasedNodeInstance.java:373)
at deployment.kie-server.war//org.jbpm.workflow.instance.node.WorkItemNodeInstance.triggerCompleted(WorkItemNodeInstance.java:293)
at deployment.kie-server.war//org.jbpm.workflow.instance.node.HumanTaskNodeInstance.triggerCompleted(HumanTaskNodeInstance.java:94)
at deployment.kie-server.war//org.jbpm.workflow.instance.node.WorkItemNodeInstance.workItemCompleted(WorkItemNodeInstance.java:380)
at deployment.kie-server.war//org.jbpm.workflow.instance.node.WorkItemNodeInstance.signalEvent(WorkItemNodeInstance.java:350)
at deployment.kie-server.war//org.jbpm.workflow.instance.impl.WorkflowProcessInstanceImpl.signalEvent(WorkflowProcessInstanceImpl.java:694)
at deployment.kie-server.war//org.drools.persistence.jpa.processinstance.JPAWorkItemManager.completeWorkItem(JPAWorkItemManager.java:171)
at deployment.kie-server.war//org.drools.core.command.runtime.process.CompleteWorkItemCommand.execute(CompleteWorkItemCommand.java:75)
at deployment.kie-server.war//org.drools.core.command.runtime.process.CompleteWorkItemCommand.execute(CompleteWorkItemCommand.java:35)
at deployment.kie-server.war//org.drools.core.fluent.impl.PseudoClockRunner.executeBatch(PseudoClockRunner.java:102)
at deployment.kie-server.war//org.drools.core.fluent.impl.PseudoClockRunner.executeBatches(PseudoClockRunner.java:69)
at deployment.kie-server.war//org.drools.core.fluent.impl.PseudoClockRunner.execute(PseudoClockRunner.java:61)
at deployment.kie-server.war//org.drools.core.fluent.impl.PseudoClockRunner.execute(PseudoClockRunner.java:39)
at deployment.kie-server.war//org.drools.core.command.impl.AbstractInterceptor.executeNext(AbstractInterceptor.java:39)
at deployment.kie-server.war//org.drools.persistence.PersistableRunner$TransactionInterceptor.execute(PersistableRunner.java:608)
at deployment.kie-server.war//org.drools.persistence.PersistableRunner$TransactionInterceptor.execute(PersistableRunner.java:568)
at deployment.kie-server.war//org.drools.core.command.impl.AbstractInterceptor.executeNext(AbstractInterceptor.java:39)
at deployment.kie-server.war//org.drools.persistence.jpa.OptimisticLockRetryInterceptor.internalExecute(OptimisticLockRetryInterceptor.java:102)
at deployment.kie-server.war//org.drools.persistence.jpa.OptimisticLockRetryInterceptor.execute(OptimisticLockRetryInterceptor.java:83)
at deployment.kie-server.war//org.drools.persistence.jpa.OptimisticLockRetryInterceptor.execute(OptimisticLockRetryInterceptor.java:44)
at deployment.kie-server.war//org.drools.core.command.impl.AbstractInterceptor.executeNext(AbstractInterceptor.java:39)
at deployment.kie-server.war//org.drools.persistence.jta.TransactionLockInterceptor.execute(TransactionLockInterceptor.java:73)
at deployment.kie-server.war//org.drools.persistence.jta.TransactionLockInterceptor.execute(TransactionLockInterceptor.java:45)
at deployment.kie-server.war//org.drools.core.command.impl.AbstractInterceptor.executeNext(AbstractInterceptor.java:39)
at deployment.kie-server.war//org.jbpm.runtime.manager.impl.error.ExecutionErrorHandlerInterceptor.internalExecute(ExecutionErrorHandlerInterceptor.java:66)
at deployment.kie-server.war//org.jbpm.runtime.manager.impl.error.ExecutionErrorHandlerInterceptor.execute(ExecutionErrorHandlerInterceptor.java:52)
at deployment.kie-server.war//org.jbpm.runtime.manager.impl.error.ExecutionErrorHandlerInterceptor.execute(ExecutionErrorHandlerInterceptor.java:29)
at deployment.kie-server.war//org.drools.persistence.PersistableRunner.execute(PersistableRunner.java:400)
at deployment.kie-server.war//org.drools.persistence.PersistableRunner.execute(PersistableRunner.java:68)
at deployment.kie-server.war//org.drools.core.runtime.InternalLocalRunner.execute(InternalLocalRunner.java:37)
at deployment.kie-server.war//org.drools.core.runtime.InternalLocalRunner.execute(InternalLocalRunner.java:41)
at deployment.kie-server.war//org.drools.core.command.impl.CommandBasedStatefulKnowledgeSession$1.completeWorkItem(CommandBasedStatefulKnowledgeSession.java:172)
at deployment.kie-server.war//org.jbpm.services.task.wih.ExternalTaskEventListener.processTaskState(ExternalTaskEventListener.java:66)
at deployment.kie-server.war//org.jbpm.services.task.wih.ExternalTaskEventListener.afterTaskCompletedEvent(ExternalTaskEventListener.java:112)
at deployment.kie-server.war//org.jbpm.services.task.events.TaskEventSupport.lambda$fireAfterTaskCompleted$27(TaskEventSupport.java:227)
at deployment.kie-server.war//org.drools.core.event.AbstractEventSupport.notifyAllListeners(AbstractEventSupport.java:63)
at deployment.kie-server.war//org.jbpm.services.task.events.TaskEventSupport.fireAfterTaskCompleted(TaskEventSupport.java:227)
at deployment.kie-server.war//org.jbpm.services.task.internals.lifecycle.MVELLifeCycleManager.taskOperation(MVELLifeCycleManager.java:411)
at deployment.kie-server.war//org.jbpm.services.task.impl.TaskInstanceServiceImpl.complete(TaskInstanceServiceImpl.java:191)
at deployment.kie-server.war//org.jbpm.services.task.commands.CompleteTaskCommand.execute(CompleteTaskCommand.java:98)
at deployment.kie-server.war//org.jbpm.services.task.commands.CompleteTaskCommand.execute(CompleteTaskCommand.java:42)
at deployment.kie-server.war//org.jbpm.services.task.commands.CompositeCommand.execute(CompositeCommand.java:146)
at deployment.kie-server.war//org.jbpm.services.task.commands.TaskCommandExecutorImpl$SelfExecutionCommandService.execute(TaskCommandExecutorImpl.java:80)
at deployment.kie-server.war//org.jbpm.services.task.commands.TaskCommandExecutorImpl$SelfExecutionCommandService.execute(TaskCommandExecutorImpl.java:65)
at deployment.kie-server.war//org.drools.core.command.impl.AbstractInterceptor.executeNext(AbstractInterceptor.java:39)
at deployment.kie-server.war//org.jbpm.services.task.persistence.TaskTransactionInterceptor.execute(TaskTransactionInterceptor.java:88)
at deployment.kie-server.war//org.jbpm.services.task.persistence.TaskTransactionInterceptor.execute(TaskTransactionInterceptor.java:49)
at deployment.kie-server.war//org.drools.core.command.impl.AbstractInterceptor.executeNext(AbstractInterceptor.java:39)
at deployment.kie-server.war//org.drools.persistence.jta.TransactionLockInterceptor.execute(TransactionLockInterceptor.java:73)
at deployment.kie-server.war//org.drools.persistence.jta.TransactionLockInterceptor.execute(TransactionLockInterceptor.java:45)
at deployment.kie-server.war//org.drools.core.command.impl.AbstractInterceptor.executeNext(AbstractInterceptor.java:39)
at deployment.kie-server.war//org.drools.persistence.jpa.OptimisticLockRetryInterceptor.internalExecute(OptimisticLockRetryInterceptor.java:102)
at deployment.kie-server.war//org.drools.persistence.jpa.OptimisticLockRetryInterceptor.execute(OptimisticLockRetryInterceptor.java:83)
at deployment.kie-server.war//org.drools.persistence.jpa.OptimisticLockRetryInterceptor.execute(OptimisticLockRetryInterceptor.java:44)
at deployment.kie-server.war//org.drools.core.command.impl.AbstractInterceptor.executeNext(AbstractInterceptor.java:39)
at deployment.kie-server.war//org.jbpm.runtime.manager.impl.error.ExecutionErrorHandlerInterceptor.internalExecute(ExecutionErrorHandlerInterceptor.java:66)
at deployment.kie-server.war//org.jbpm.runtime.manager.impl.error.ExecutionErrorHandlerInterceptor.execute(ExecutionErrorHandlerInterceptor.java:52)
at deployment.kie-server.war//org.jbpm.runtime.manager.impl.error.ExecutionErrorHandlerInterceptor.execute(ExecutionErrorHandlerInterceptor.java:29)
at deployment.kie-server.war//org.drools.core.runtime.InternalLocalRunner.execute(InternalLocalRunner.java:37)
at deployment.kie-server.war//org.drools.core.runtime.InternalLocalRunner.execute(InternalLocalRunner.java:41)
at deployment.kie-server.war//org.jbpm.services.task.commands.TaskCommandExecutorImpl.execute(TaskCommandExecutorImpl.java:49)
at deployment.kie-server.war//org.jbpm.services.task.impl.command.CommandBasedTaskService.complete(CommandBasedTaskService.java:176)
at deployment.kie-server.war//org.jbpm.runtime.manager.impl.task.SynchronizedTaskService.complete(SynchronizedTaskService.java:118)
at deployment.kie-server.war//org.jbpm.kie.services.impl.UserTaskServiceImpl.complete(UserTaskServiceImpl.java:230)
at deployment.kie-server.war//org.kie.server.services.jbpm.UserTaskServiceBase.complete(UserTaskServiceBase.java:111)
at deployment.kie-server.war//org.kie.server.remote.rest.jbpm.UserTaskResource.complete(UserTaskResource.java:258)
at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.base/java.lang.reflect.Method.invoke(Method.java:566)
at org.jboss.restea...@3.15.1.Final//org.jboss.resteasy.core.MethodInjectorImpl.invoke(MethodInjectorImpl.java:138)
at org.jboss.restea...@3.15.1.Final//org.jboss.resteasy.core.ResourceMethodInvoker.internalInvokeOnTarget(ResourceMethodInvoker.java:546)
at org.jboss.restea...@3.15.1.Final//org.jboss.resteasy.core.ResourceMethodInvoker.invokeOnTargetAfterFilter(ResourceMethodInvoker.java:435)
at org.jboss.restea...@3.15.1.Final//org.jboss.resteasy.core.ResourceMethodInvoker.lambda$invokeOnTarget$0(ResourceMethodInvoker.java:396)
at org.jboss.restea...@3.15.1.Final//org.jboss.resteasy.core.interception.PreMatchContainerRequestContext.filter(PreMatchContainerRequestContext.java:358)
at org.jboss.restea...@3.15.1.Final//org.jboss.resteasy.core.ResourceMethodInvoker.invokeOnTarget(ResourceMethodInvoker.java:398)
at org.jboss.restea...@3.15.1.Final//org.jboss.resteasy.core.ResourceMethodInvoker.invoke(ResourceMethodInvoker.java:365)
at org.jboss.restea...@3.15.1.Final//org.jboss.resteasy.core.ResourceMethodInvoker.invoke(ResourceMethodInvoker.java:338)
at org.jboss.restea...@3.15.1.Final//org.jboss.resteasy.core.SynchronousDispatcher.invoke(SynchronousDispatcher.java:440)
at org.jboss.restea...@3.15.1.Final//org.jboss.resteasy.core.SynchronousDispatcher.lambda$invoke$4(SynchronousDispatcher.java:229)
at org.jboss.restea...@3.15.1.Final//org.jboss.resteasy.core.SynchronousDispatcher.lambda$preprocess$0(SynchronousDispatcher.java:135)
at org.jboss.restea...@3.15.1.Final//org.jboss.resteasy.core.interception.PreMatchContainerRequestContext.filter(PreMatchContainerRequestContext.java:358)
at org.jboss.restea...@3.15.1.Final//org.jboss.resteasy.core.SynchronousDispatcher.preprocess(SynchronousDispatcher.java:138)
at org.jboss.restea...@3.15.1.Final//org.jboss.resteasy.core.SynchronousDispatcher.invoke(SynchronousDispatcher.java:215)
at org.jboss.restea...@3.15.1.Final//org.jboss.resteasy.plugins.server.servlet.ServletContainerDispatcher.service(ServletContainerDispatcher.java:245)
at org.jboss.restea...@3.15.1.Final//org.jboss.resteasy.plugins.server.servlet.HttpServletDispatcher.service(HttpServletDispatcher.java:61)
at org.jboss.restea...@3.15.1.Final//org.jboss.resteasy.plugins.server.servlet.HttpServletDispatcher.service(HttpServletDispatcher.java:56)
at javax.se...@2.0.0.Final//javax.servlet.http.HttpServlet.service(HttpServlet.java:590)
at io.undert...@2.2.5.Final//io.undertow.servlet.handlers.ServletHandler.handleRequest(ServletHandler.java:74)
at io.undert...@2.2.5.Final//io.undertow.servlet.handlers.security.ServletSecurityRoleHandler.handleRequest(ServletSecurityRoleHandler.java:62)
at io.undert...@2.2.5.Final//io.undertow.servlet.handlers.ServletChain$1.handleRequest(ServletChain.java:68)
at io.undert...@2.2.5.Final//io.undertow.servlet.handlers.ServletDispatchingHandler.handleRequest(ServletDispatchingHandler.java:36)
at org.wildfly.ext...@23.0.2.Final//org.wildfly.extension.undertow.security.SecurityContextAssociationHandler.handleRequest(SecurityContextAssociationHandler.java:78)
at io.under...@2.2.5.Final//io.undertow.server.handlers.PredicateHandler.handleRequest(PredicateHandler.java:43)
at io.undert...@2.2.5.Final//io.undertow.servlet.handlers.RedirectDirHandler.handleRequest(RedirectDirHandler.java:68)
at io.undert...@2.2.5.Final//io.undertow.servlet.handlers.security.SSLInformationAssociationHandler.handleRequest(SSLInformationAssociationHandler.java:117)
at io.undert...@2.2.5.Final//io.undertow.servlet.handlers.security.ServletAuthenticationCallHandler.handleRequest(ServletAuthenticationCallHandler.java:57)
at io.under...@2.2.5.Final//io.undertow.server.handlers.DisableCacheHandler.handleRequest(DisableCacheHandler.java:33)
at io.under...@2.2.5.Final//io.undertow.server.handlers.PredicateHandler.handleRequest(PredicateHandler.java:43)
at io.under...@2.2.5.Final//io.undertow.security.handlers.AuthenticationConstraintHandler.handleRequest(AuthenticationConstraintHandler.java:53)
at io.under...@2.2.5.Final//io.undertow.security.handlers.AbstractConfidentialityHandler.handleRequest(AbstractConfidentialityHandler.java:46)
at io.undert...@2.2.5.Final//io.undertow.servlet.handlers.security.ServletConfidentialityConstraintHandler.handleRequest(ServletConfidentialityConstraintHandler.java:64)
at io.undert...@2.2.5.Final//io.undertow.servlet.handlers.security.ServletSecurityConstraintHandler.handleRequest(ServletSecurityConstraintHandler.java:59)
at io.under...@2.2.5.Final//io.undertow.security.handlers.AuthenticationMechanismsHandler.handleRequest(AuthenticationMechanismsHandler.java:60)
at io.undert...@2.2.5.Final//io.undertow.servlet.handlers.security.CachedAuthenticatedSessionHandler.handleRequest(CachedAuthenticatedSessionHandler.java:77)
at io.under...@2.2.5.Final//io.undertow.security.handlers.NotificationReceiverHandler.handleRequest(NotificationReceiverHandler.java:50)
at io.under...@2.2.5.Final//io.undertow.security.handlers.AbstractSecurityContextAssociationHandler.handleRequest(AbstractSecurityContextAssociationHandler.java:43)
at io.under...@2.2.5.Final//io.undertow.server.handlers.PredicateHandler.handleRequest(PredicateHandler.java:43)
at org.wildfly.ext...@23.0.2.Final//org.wildfly.extension.undertow.security.jacc.JACCContextIdHandler.handleRequest(JACCContextIdHandler.java:61)
at io.under...@2.2.5.Final//io.undertow.server.handlers.PredicateHandler.handleRequest(PredicateHandler.java:43)
at org.wildfly.ext...@23.0.2.Final//org.wildfly.extension.undertow.deployment.GlobalRequestControllerHandler.handleRequest(GlobalRequestControllerHandler.java:68)
at io.undert...@2.2.5.Final//io.undertow.servlet.handlers.SendErrorPageHandler.handleRequest(SendErrorPageHandler.java:52)
at io.under...@2.2.5.Final//io.undertow.server.handlers.PredicateHandler.handleRequest(PredicateHandler.java:43)
at io.undert...@2.2.5.Final//io.undertow.servlet.handlers.ServletInitialHandler.handleFirstRequest(ServletInitialHandler.java:269)
at io.undert...@2.2.5.Final//io.undertow.servlet.handlers.ServletInitialHandler.access$100(ServletInitialHandler.java:78)
at io.undert...@2.2.5.Final//io.undertow.servlet.handlers.ServletInitialHandler$2.call(ServletInitialHandler.java:133)
at io.undert...@2.2.5.Final//io.undertow.servlet.handlers.ServletInitialHandler$2.call(ServletInitialHandler.java:130)
at io.undert...@2.2.5.Final//io.undertow.servlet.core.ServletRequestContextThreadSetupAction$1.call(ServletRequestContextThreadSetupAction.java:48)
at io.undert...@2.2.5.Final//io.undertow.servlet.core.ContextClassLoaderSetupAction$1.call(ContextClassLoaderSetupAction.java:43)
at org.wildfly.ext...@23.0.2.Final//org.wildfly.extension.undertow.security.SecurityContextThreadSetupAction.lambda$create$0(SecurityContextThreadSetupAction.java:105)
at org.wildfly.ext...@23.0.2.Final//org.wildfly.extension.undertow.deployment.UndertowDeploymentInfoService$UndertowThreadSetupAction.lambda$create$0(UndertowDeploymentInfoService.java:1530)
at org.wildfly.ext...@23.0.2.Final//org.wildfly.extension.undertow.deployment.UndertowDeploymentInfoService$UndertowThreadSetupAction.lambda$create$0(UndertowDeploymentInfoService.java:1530)
at org.wildfly.ext...@23.0.2.Final//org.wildfly.extension.undertow.deployment.UndertowDeploymentInfoService$UndertowThreadSetupAction.lambda$create$0(UndertowDeploymentInfoService.java:1530)
at org.wildfly.ext...@23.0.2.Final//org.wildfly.extension.undertow.deployment.UndertowDeploymentInfoService$UndertowThreadSetupAction.lambda$create$0(UndertowDeploymentInfoService.java:1530)
at io.undert...@2.2.5.Final//io.undertow.servlet.handlers.ServletInitialHandler.dispatchRequest(ServletInitialHandler.java:249)
at io.undert...@2.2.5.Final//io.undertow.servlet.handlers.ServletInitialHandler.access$000(ServletInitialHandler.java:78)
at io.undert...@2.2.5.Final//io.undertow.servlet.handlers.ServletInitialHandler$1.handleRequest(ServletInitialHandler.java:99)
at io.under...@2.2.5.Final//io.undertow.server.Connectors.executeRootHandler(Connectors.java:387)
at io.under...@2.2.5.Final//io.undertow.server.HttpServerExchange$1.run(HttpServerExchange.java:841)
at org.jbos...@2.4.0.Final//org.jboss.threads.ContextClassLoaderSavingRunnable.run(ContextClassLoaderSavingRunnable.java:35)
at org.jbos...@2.4.0.Final//org.jboss.threads.EnhancedQueueExecutor.safeRun(EnhancedQueueExecutor.java:1990)
at org.jbos...@2.4.0.Final//org.jboss.threads.EnhancedQueueExecutor$ThreadBody.doRunTask(EnhancedQueueExecutor.java:1486)
at org.jbos...@2.4.0.Final//org.jboss.threads.EnhancedQueueExecutor$ThreadBody.run(EnhancedQueueExecutor.java:1377)
at org.jbo...@3.8.4.Final//org.xnio.XnioWorker$WorkerThreadFactory$1$1.run(XnioWorker.java:1280)
at java.base/java.lang.Thread.run(Thread.java:834)
Caused by: org.jbpm.bpmn2.handler.WorkItemHandlerRuntimeException: java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.TimeoutException: Topic rule-events not present in metadata after 60000 ms.
at deployment.kie-server.war//org.jbpm.process.workitem.core.AbstractLogOrThrowWorkItemHandler.handleException(AbstractLogOrThrowWorkItemHandler.java:69)
at deployment.kie-server.war//org.jbpm.process.workitem.core.AbstractLogOrThrowWorkItemHandler.handleException(AbstractLogOrThrowWorkItemHandler.java:45)
at org.jbpm.process.workitem.kafka.KafkaWorkItemHandler.executeWorkItem(KafkaWorkItemHandler.java:258)
at deployment.kie-server.war//org.drools.persistence.jpa.processinstance.JPAWorkItemManager.internalExecuteWorkItem(JPAWorkItemManager.java:69)
at deployment.kie-server.war//org.jbpm.workflow.instance.node.WorkItemNodeInstance.lambda$internalTrigger$0(WorkItemNodeInstance.java:141)
at deployment.kie-server.war//org.jbpm.workflow.instance.node.WorkItemNodeInstance.processWorkItemHandler(WorkItemNodeInstance.java:155)
... 142 more
Caused by: java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.TimeoutException: Topic rule-events not present in metadata after 60000 ms.
at deployment.kie-server.war//org.apache.kafka.clients.producer.KafkaProducer$FutureFailure.<init>(KafkaProducer.java:1316)
at deployment.kie-server.war//org.apache.kafka.clients.producer.KafkaProducer.doSend(KafkaProducer.java:985)
at deployment.kie-server.war//org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:885)
at deployment.kie-server.war//org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:773)
at org.jbpm.process.workitem.kafka.KafkaWorkItemHandler.executeWorkItem(KafkaWorkItemHandler.java:233)
... 145 more
Caused by: org.apache.kafka.common.errors.TimeoutException: Topic rule-events not present in metadata after 60000 ms.

06:07:05,437 WARN [org.apache.kafka.clients.NetworkClient] (kafka-producer-network-thread | producer-1) [Producer clientId=producer-1] Connection to node 1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
06:07:05,648 WARN [org.apache.kafka.clients.NetworkClient] (kafka-producer-network-thread | autobahn-rules) [Producer clientId=autobahn-rules] Connection to node 1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
06:07:06,543 WARN [org.apache.kafka.clients.NetworkClient] (kafka-producer-network-thread | producer-1) [Producer clientId=producer-1] Connection to node 1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
06:07:06,587 WARN [org.apache.kafka.clients.NetworkClient] (kafka-producer-network-thread | autobahn-rules) [Producer clientId=autobahn-rules] Connection to node 1 (localhost/127.0.0.1:9092) could not be establish

Need your help to know if any config is missing.

Attached process.

Thanks,

Pankaj K.

Screenshot 2024-05-27 at 11.26.02 AM.png

Reply all

Reply to author

Forward

0 new messages