'How do I solve the problem of ksqlDB internal topic issue

There is an error that the default_ksql_processing_log topic does not exist even though the KsqlDB cluster is set up on three servers and the ksql.service.id value is added to each server setting.
Which part should I check?

org.apache.kafka.streams.errors.StreamsException: Exception caught in process. taskId=0_2, processor=KSTREAM-SOURCE-0000000000, topic=source.topic, partition=2, offset=3264427, stacktrace=java.lang.RuntimeException: java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.TimeoutException: Topic default_ksql_processing_log not present in metadata after 60000 ms.
    at org.apache.kafka.log4jappender.KafkaLog4jAppender.append(KafkaLog4jAppender.java:355)
    at org.apache.log4j.AppenderSkeleton.doAppend(AppenderSkeleton.java:251)
    at org.apache.log4j.helpers.AppenderAttachableImpl.appendLoopOnAppenders(AppenderAttachableImpl.java:66)
    at org.apache.log4j.Category.callAppenders(Category.java:206)
    at org.apache.log4j.Category.forcedLog(Category.java:391)
    at org.apache.log4j.Category.log(Category.java:856)
    at org.slf4j.impl.Log4jLoggerAdapter.error(Log4jLoggerAdapter.java:518)
    at io.confluent.common.logging.StructuredLoggerImpl.error(StructuredLoggerImpl.java:44)
    at io.confluent.common.logging.StructuredLoggerImpl.error(StructuredLoggerImpl.java:40)
    at io.confluent.ksql.logging.processing.ProcessingLoggerImpl.error(ProcessingLoggerImpl.java:35)
    at io.confluent.ksql.execution.streams.GroupByParamsFactory.processColumn(GroupByParamsFactory.java:93)
    at io.confluent.ksql.execution.streams.GroupByParamsFactory.access$100(GroupByParamsFactory.java:38)
    at io.confluent.ksql.execution.streams.GroupByParamsFactory$ExpressionGrouper.apply(GroupByParamsFactory.java:141)
...
...
Caused by: java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.TimeoutException: Topic default_ksql_processing_log not present in metadata after 60000 ms.
    at org.apache.kafka.clients.producer.KafkaProducer$FutureFailure.<init>(KafkaProducer.java:1320)
    at org.apache.kafka.clients.producer.KafkaProducer.doSend(KafkaProducer.java:989)
    at org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:889)
    at org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:775)
    at org.apache.kafka.log4jappender.KafkaLog4jAppender.append(KafkaLog4jAppender.java:348)
    ... 46 more
Caused by: org.apache.kafka.common.errors.TimeoutException: Topic default_ksql_processing_log not present in metadata after 60000 ms.
ksqldb


Sources

This article follows the attribution requirements of Stack Overflow and is licensed under CC BY-SA 3.0.

Source: Stack Overflow

Solution Source

Related Questions