I’m testing K2K against my MSK Serverless instances. It’s complaining of “MissingControlTopic”
k2k_1 | INFO: Received a collection of 1 metrics for export.
k2k_1 | Jul 14, 2025 8:59:54 PM io.opentelemetry.exporter.logging.LoggingMetricExporter export
k2k_1 | INFO: metric: ImmutableMetricData{resource=Resource{schemaUrl=null, attributes={service.name="k2k", telemetry.sdk.language="java", telemetry.sdk.name="opentelemetry", telemetry.sdk.version="1.49.0"}}, instrumentationScopeInfo=InstrumentationScopeInfo{name=io.opentelemetry.runtime-telemetry-java8, version=2.10.0-alpha, schemaUrl=null, attributes={}}, name=jvm.gc.duration, description=Duration of JVM garbage collection actions., unit=s, type=HISTOGRAM, data=ImmutableHistogramData{aggregationTemporality=CUMULATIVE, points=[ImmutableHistogramPointData{getStartEpochNanos=1752526792564316917, getEpochNanos=1752526794073972193, getAttributes={jvm.gc.action="end of minor GC", jvm.gc.name="G1 Young Generation"}, getSum=0.022, getCount=3, hasMin=true, getMin=0.007, hasMax=true, getMax=0.008, getBoundaries=[0.01, 0.1, 1.0, 10.0], getCounts=[3, 0, 0, 0, 0], getExemplars=[]}]}}
k2k_1 | scala.MatchError: io.lenses.k2k.model.error.K2KError$PipelineRuntimeError$MissingControlTopic (of class io.lenses.k2k.model.error.K2KError$PipelineRuntimeError$MissingControlTopic)
k2k_1 | at io.lenses.k2k.main.message.Log$.k2KError(Log.scala:214)
k2k_1 | at io.lenses.k2k.main.Main$.main$$anonfun$1$$anonfun$4$$anonfun$1(Main.scala:43)
k2k_1 | at org.typelevel.log4cats.slf4j.internal.Slf4jLoggerInternal$Slf4jLogger.error$$anonfun$1$$anonfun$1(Slf4jLoggerInternal.scala:112)
k2k_1 | at org.typelevel.log4cats.slf4j.internal.Slf4jLoggerInternal$Slf4jLogger.error$$anonfun$1$$anonfun$adapted$1(Slf4jLoggerInternal.scala:112)
k2k_1 | at suspend @ org.typelevel.log4cats.slf4j.internal.Slf4jLoggerInternal$Slf4jLogger.error$$anonfun$1(Slf4jLoggerInternal.scala:112)
k2k_1 | at delay @ org.typelevel.log4cats.slf4j.internal.Slf4jLoggerInternal$Slf4jLogger.isErrorEnabled(Slf4jLoggerInternal.scala:76)
k2k_1 | at ifM$extension @ org.typelevel.log4cats.slf4j.internal.Slf4jLoggerInternal$Slf4jLogger.info(Slf4jLoggerInternal.scala:99)
k2k_1 | at as @ com.monovore.decline.effect.CommandIOApp$.addVersionFlag(CommandIOApp.scala:67)
k2k_k2k_1 exited with code 1