Problem

Starting StackState results in the following similar log messages in /opt/stackstate/var/logprocessmanager.log;

2020-06-03 06:11:58,292 [kafka-topics-akka.actor.default-dispatcher-3] INFO  c.s.p.processcontroller.KafkaTopicsSpecification$ - Creating topic sts_topo_trace_agents
2020-06-03 06:11:58,292 [kafka-topics-akka.actor.default-dispatcher-3] INFO  c.s.p.processcontroller.KafkaTopicsSpecification$ - Creating topic sts_state_events
2020-06-03 06:11:58,293 [kafka-topics-akka.actor.default-dispatcher-3] INFO  c.s.p.processcontroller.KafkaTopicsSpecification$ - Creating topic sts_topo_process_agents
2020-06-03 06:11:58,294 [kafka-topics-akka.actor.default-dispatcher-3] INFO  c.s.p.processcontroller.KafkaTopicsSpecification$ - Creating topic sts_correlate_endpoints
2020-06-03 06:11:58,417 [kafka-topics-akka.actor.default-dispatcher-3] ERROR com.stackstate.kafka.StsKafkaAdminClient - Failed to create topic sts_internal_events.
org.apache.kafka.common.errors.TopicExistsException: Topic 'sts_internal_events' already exists.
2020-06-03 06:11:58,426 [kafka-topics-akka.actor.default-dispatcher-3] ERROR com.stackstate.kafka.StsKafkaAdminClient - Failed to create topic sts_generic_events.
org.apache.kafka.common.errors.TopicExistsException: Topic 'sts_generic_events' already exists.
2020-06-03 06:11:58,431 [kafka-topics-akka.actor.default-dispatcher-3] ERROR com.stackstate.kafka.StsKafkaAdminClient - Failed to create topic sts_connection_beat_events.
org.apache.kafka.common.errors.TopicExistsException: Topic 'sts_connection_beat_events' already exists.
2020-06-03 06:11:58,431 [kafka-topics-akka.actor.default-dispatcher-3] ERROR com.stackstate.kafka.StsKafkaAdminClient - Failed to create topic sts_trace_events.
org.apache.kafka.common.errors.TopicExistsException: Topic 'sts_trace_events' already exists.
2020-06-03 06:11:58,434 [kafka-topics-akka.actor.default-dispatcher-6] ERROR com.stackstate.kafka.StsKafkaAdminClient - Failed to create topic sts_multi_metrics.
org.apache.kafka.common.errors.TopicExistsException: Topic 'sts_multi_metrics' already exists.
2020-06-03 06:11:58,436 [kafka-topics-akka.actor.default-dispatcher-6] ERROR com.stackstate.kafka.StsKafkaAdminClient - Failed to create topic sts_topo_trace_agents.
org.apache.kafka.common.errors.TopicExistsException: Topic 'sts_topo_trace_agents' already exists.
2020-06-03 06:11:58,441 [kafka-topics-akka.actor.default-dispatcher-6] ERROR com.stackstate.kafka.StsKafkaAdminClient - Failed to create topic sts_state_events.
org.apache.kafka.common.errors.TopicExistsException: Topic 'sts_state_events' already exists.
2020-06-03 06:11:58,443 [kafka-topics-akka.actor.default-dispatcher-6] ERROR com.stackstate.kafka.StsKafkaAdminClient - Failed to create topic sts_topo_process_agents.
org.apache.kafka.common.errors.TopicExistsException: Topic 'sts_topo_process_agents' already exists.
2020-06-03 06:11:58,451 [kafka-topics-akka.actor.default-dispatcher-6] ERROR com.stackstate.kafka.StsKafkaAdminClient - Failed to create topic sts_correlate_endpoints.
org.apache.kafka.common.errors.TopicExistsException: Topic 'sts_correlate_endpoints' already exists.
2020-06-03 06:11:58,454 [kafka-topics-akka.actor.default-dispatcher-3] ERROR c.s.p.processcontroller.KafkaTopicsSpecification$ - Failed to create/configure Kafka topics.
com.stackstate.kafka.StsKafkaAdminClient$TopicOperationException: Topic sts_multi_metrics: Creation failed.
        at com.stackstate.kafka.StsKafkaAdminClient.$anonfun$createTopic$3(StsKafkaAdminClient.scala:114)
        at scala.concurrent.Future.$anonfun$transform$3(Future.scala:245)
        at scala.concurrent.Future.$anonfun$transform$1(Future.scala:245)
        at scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
        at scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
        at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
        at akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:55)
        at akka.dispatch.BatchingExecutor$BlockableBatch.$anonfun$run$1(BatchingExecutor.scala:92)
        at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:23)
        at scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:85)
        at akka.dispatch.BatchingExecutor$BlockableBatch.run(BatchingExecutor.scala:92)
        at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:41)
        at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(ForkJoinExecutorConfigurator.scala:49)
        at akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
        at akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
        at akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
        at akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
Caused by: org.apache.kafka.common.errors.TopicExistsException: Topic 'sts_multi_metrics' already exists.
2020-06-03 06:11:59,632 [kafka-topics-akka.actor.default-dispatcher-13] INFO  c.s.p.processcontroller.KafkaTopicsSpecification$ - Alter topic sts_internal_events
2020-06-03 06:11:59,639 [kafka-topics-akka.actor.default-dispatcher-13] INFO  c.s.p.processcontroller.KafkaTopicsSpecification$ - Alter topic sts_generic_events
2020-06-03 06:11:59,656 [kafka-topics-akka.actor.default-dispatcher-13] INFO  c.s.p.processcontroller.KafkaTopicsSpecification$ - Alter topic sts_connection_beat_events
2020-06-03 06:11:59,658 [kafka-topics-akka.actor.default-dispatcher-13] INFO  c.s.p.processcontroller.KafkaTopicsSpecification$ - Alter topic sts_trace_events
2020-06-03 06:11:59,659 [kafka-topics-akka.actor.default-dispatcher-13] INFO  c.s.p.processcontroller.KafkaTopicsSpecification$ - Alter topic sts_multi_metrics
2020-06-03 06:11:59,660 [kafka-topics-akka.actor.default-dispatcher-13] INFO  c.s.p.processcontroller.KafkaTopicsSpecification$ - Alter topic sts_topo_trace_agents
2020-06-03 06:11:59,660 [kafka-topics-akka.actor.default-dispatcher-13] INFO  c.s.p.processcontroller.KafkaTopicsSpecification$ - Alter topic sts_state_events
2020-06-03 06:11:59,660 [kafka-topics-akka.actor.default-dispatcher-13] INFO  c.s.p.processcontroller.KafkaTopicsSpecification$ - Alter topic sts_topo_process_agents
2020-06-03 06:11:59,660 [kafka-topics-akka.actor.default-dispatcher-13] INFO  c.s.p.processcontroller.KafkaTopicsSpecification$ - Alter topic sts_correlate_endpoints
  

Cause

During startup, StackState creates Kafka topics that it uses internally. These log messages are shown in the log file when the Kafka topics already exists. It couldn't create Kafka topics that are already available.

Affects

• StackState release version 4.0.x

Solution

The log messages can be ignored. This will be resolved in a future release of StackState.