KStream 加入在 kubernetes env 中不起作用，但在本地运行良好

问：

我有一个简单的应用程序，它将使用来自 topicA 和 topicB 的两个流，将它们转换为 KTables，然后使用外键连接两个表。然后，将联接的结果发送到输出主题。在本地环境中，应用程序运行良好，但是当我将其托管在Kubernetes中时，我可以看到Ktables正在接收消息，但未触发连接。

我将 KTables 转换为 Stream 并安慰键和值，并得出结论 KTables 正在接收消息。类似的日志在传递到输出主题和 ValueJoiner 内部之前被放置，但无济于事。复制因子为 1，应用程序有自己的组。我还检查了内部中间外部连接主题，它们也是空的。有人可以给出一些关于如何调试的指示。

KTable<String, GenericRecord> tableA = kafkaStreamService.getKTable(
                builder,
                "TOPICA",
                tableAMapper
        );
      
        KTable<String, GenericRecord> tableB= kafkaStreamService.getKTable(
                builder,
                "TOPICB",
                tableBMapper
        );
    
        KTable<String, GenericRecord> joinedTable = tableA.leftJoin(
                tableB,
                keyExtractor,
                joiner
        );

        KStream<String,GenericRecord> joinedStream = joinedTable.toStream();
        appointmentLabDetailAndAppointmentStream.to("OUTPUT_TOPIC");

kafkaStreamService.getKTable 接收流执行一些 processign，然后使用processedStream.toTable(Materialized.with(Serdes.String(), genericAvroSerde));