显式指定 KSQL 流主题名称

我有两个 KSQL 主题my-topic-1 and my-topic-2，消息通过 AVRO 序列化。由于历史原因，my-topic-1架构不在推荐范围内topic-value格式，而是my-custom-subject-name.

我想通过 KSQL 将记录从一个主题移动到另一主题。

首先，让我们创建一个流：

CREATE STREAM my-stream-1
    WITH (KAFKA_TOPIC='my-topic-1', VALUE_FORMAT='AVRO');

oops:

Avro schema for message values on topic my-topic-1 does not exist in the Schema Registry.
Subject: my-topic-1-value

Possible causes include:
- The topic itself does not exist
        -> Use SHOW TOPICS; to check
- Messages on the topic are not Avro serialized
        -> Use PRINT 'my-topic-1' FROM BEGINNING; to verify
- Messages on the topic have not been serialized using the Confluent Schema Registry Avro serializer
        -> See https://docs.confluent.io/current/schema-registry/docs/serializer-formatter.html
- The schema is registered on a different instance of the Schema Registry
        -> Use the REST API to list available subjects
        https://docs.confluent.io/current/schema-registry/docs/api.html#get--subjects

正在寻找主题my-topic-1-value

有谁知道这是否可能？VALUE_AVRO_SCHEMA_FULL_NAME提及here https://docs.confluent.io/current/ksql/docs/installation/server-config/avro-schema.html#using-avro-in-ksql没有做我想做的事。

这似乎是一个错误。我已经更新了https://github.com/confluenceinc/ksql/issues/3188 https://github.com/confluentinc/ksql/issues/3188并举一个重现的例子。我建议我们在那里追踪它。