Failed to construct kafka consumer

[cli00004]

Description
Run the all in one docker compose file, and go to ksqldb and create a query

[2025-04-15 03:25:39,212] ERROR Failed to execute query (io.confluent.ksql.api.server.ServerUtils)

org.apache.kafka.common.KafkaException: Failed to construct kafka consumer

	at org.apache.kafka.clients.consumer.internals.ClassicKafkaConsumer.<init>(ClassicKafkaConsumer.java:271)

	at org.apache.kafka.clients.consumer.internals.ConsumerDelegateCreator.create(ConsumerDelegateCreator.java:65)

	at org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:600)

	at org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:595)

	at org.apache.kafka.streams.processor.internals.DefaultKafkaClientSupplier.getRestoreConsumer(DefaultKafkaClientSupplier.java:49)

	at org.apache.kafka.streams.processor.internals.StreamThread.create(StreamThread.java:385)

	at org.apache.kafka.streams.KafkaStreams.createAndAddStreamThread(KafkaStreams.java:1066)

	at org.apache.kafka.streams.KafkaStreams.<init>(KafkaStreams.java:1058)

	at org.apache.kafka.streams.KafkaStreams.<init>(KafkaStreams.java:950)

	at org.apache.kafka.streams.KafkaStreams.<init>(KafkaStreams.java:856)

	at io.confluent.ksql.query.KafkaStreamsBuilderImpl.build(KafkaStreamsBuilderImpl.java:34)

	at io.confluent.ksql.util.QueryMetadataImpl.initialize(QueryMetadataImpl.java:181)

	at io.confluent.ksql.query.QueryRegistryImpl.createStreamPullQuery(QueryRegistryImpl.java:232)

	at io.confluent.ksql.engine.EngineExecutor.executeStreamPullQuery(EngineExecutor.java:494)

	at io.confluent.ksql.engine.KsqlEngine.createStreamPullQuery(KsqlEngine.java:425)

	at io.confluent.ksql.rest.server.query.QueryExecutor.handleStreamPullQuery(QueryExecutor.java:372)

	at io.confluent.ksql.rest.server.query.QueryExecutor.handleQuery(QueryExecutor.java:209)

	at io.confluent.ksql.rest.server.query.QueryExecutor.handleStatement(QueryExecutor.java:128)

	at io.confluent.ksql.api.impl.QueryEndpoint.createQueryPublisher(QueryEndpoint.java:107)

	at io.confluent.ksql.rest.server.KsqlServerEndpoints.lambda$createQueryPublisher$0(KsqlServerEndpoints.java:147)

	at io.confluent.ksql.rest.server.KsqlServerEndpoints.lambda$executeOnWorker$23(KsqlServerEndpoints.java:334)

	at io.vertx.core.impl.ContextBase.lambda$executeBlocking$1(ContextBase.java:180)

	at io.vertx.core.impl.ContextInternal.dispatch(ContextInternal.java:277)

	at io.vertx.core.impl.ContextBase.lambda$internalExecuteBlocking$2(ContextBase.java:199)

	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)

	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)

	at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)

	at java.base/java.lang.Thread.run(Unknown Source)

Caused by: org.apache.kafka.common.KafkaException: Class io.confluent.monitoring.clients.interceptor.MonitoringConsumerInterceptor cannot be found

	at org.apache.kafka.common.config.AbstractConfig.getConfiguredInstance(AbstractConfig.java:399)

	at org.apache.kafka.common.config.AbstractConfig.getConfiguredInstances(AbstractConfig.java:490)

	at org.apache.kafka.common.config.AbstractConfig.getConfiguredInstances(AbstractConfig.java:468)

	at org.apache.kafka.clients.ClientUtils.configuredInterceptors(ClientUtils.java:293)

	at org.apache.kafka.clients.consumer.internals.ConsumerUtils.configuredConsumerInterceptors(ConsumerUtils.java:170)

	at org.apache.kafka.clients.consumer.internals.ClassicKafkaConsumer.<init>(ClassicKafkaConsumer.java:181)

�
	... 27 more

Caused by: java.lang.ClassNotFoundException: io.confluent.monitoring.clients.interceptor.MonitoringConsumerInterceptor

	at java.base/jdk.internal.loader.BuiltinClassLoader.loadClass(Unknown Source)

	at java.base/jdk.internal.loader.ClassLoaders$AppClassLoader.loadClass(Unknown Source)

	at java.base/java.lang.ClassLoader.loadClass(Unknown Source)

	at org.apache.kafka.common.utils.Utils.loadClass(Utils.java:442)

	at org.apache.kafka.common.utils.Utils.newInstance(Utils.java:427)

	at org.apache.kafka.common.config.AbstractConfig.getConfiguredInstance(AbstractConfig.java:397)

Troubleshooting
Identify any existing issues that seem related: https://github.com/confluentinc/cp-all-in-one/issues?q=is%3Aissue

If applicable, please include the output of:

• docker-compose logs <container name>
• any other relevant commands

Environment

• GitHub branch: [e.g. 6.0.1-post, etc]
• Operating System:
• Version of Docker:
• Version of Docker Compose:

[rbarrott-confluent]

A quick fix for this issue is to comment out these lines in cp-all-in-one/cp-all-in-one/docker-compose.yml

#KSQL_PRODUCER_INTERCEPTOR_CLASSES: "io.confluent.monitoring.clients.interceptor.MonitoringProducerInterceptor"
#KSQL_CONSUMER_INTERCEPTOR_CLASSES: "io.confluent.monitoring.clients.interceptor.MonitoringConsumerInterceptor"