Присоединение к KTable с KStream, и в выходной теме ничего не приходит

Я покинул KStream с помощью KTable, но не вижу вывода в тему вывода:

  val stringSerde: Serde[String] = Serdes.String()
  val longSerde: Serde[java.lang.Long] = Serdes.Long()
  val genericRecordSerde: Serde[GenericRecord] = new GenericAvroSerde()

  val builder = new KStreamBuilder()

  val networkImprStream: KStream[Long, GenericRecord] = builder
    .stream(dfpGcsNetworkImprEnhanced)

  // Create a global table for advertisers. The data from this global table
  // will be fully replicated on each instance of this application.
  val advertiserTable: GlobalKTable[java.lang.Long, GenericRecord]= builder.globalTable(advertiserTopicName, "advertiser-store")

  // Join the network impr stream to the advertiser global table. As this is global table
  // we can use a non-key based join with out needing to repartition the input stream
  val networkImprWithAdvertiserNameKStream: KStream[java.lang.Long, GenericRecord] = networkImprStream.leftJoin(advertiserTable,
    (_, networkImpr) => {
      println(networkImpr)
      networkImpr.get("advertiserId").asInstanceOf[java.lang.Long]
    },
    (networkImpr: GenericRecord, adertiserIdToName: GenericRecord) => {
      println(networkImpr)
      networkImpr.put("advertiserName", adertiserIdToName.get("name"))
      networkImpr
    }
  )

  networkImprWithAdvertiserNameKStream.to(networkImprProcessed)

  val streams = new KafkaStreams(builder, streamsConfiguration)
  streams.cleanUp()
  streams.start()
  // usually the stream application would be running forever,
  // in this example we just let it run for some time and stop since the input data is finite.
  Thread.sleep(15000L)

Если я пропущу соединение и напрямую выведу входную тему в выход, я увижу приходящие сообщения. Я уже изменил соединение на левое соединение, добавил несколько printlns, чтобы увидеть, когда ключ извлечен (хотя на консоли ничего не печатается). Также я каждый раз использую инструмент сброса потоков kafka, поэтому начинаю с самого начала. Здесь у меня заканчиваются идеи. Также я добавил тестовый доступ к магазину, он работает и содержит ключи из потока (хотя это не должно запрещать какой-либо вывод из-за левого соединения).