创建的Kafka Stream无法从Topic加载事件问题求助

我正在做一个简单的流POC，验证Stream能否从Topic提取事件，但创建的Stream始终无法加载数据。操作步骤如下：

• 在Control Center控制台手动创建默认配置的Topic，命名为my_topic；
• 在Schema模块添加如下AVRO Schema：

{
  "connect.name": "io.confluent.ksql.avro_schemas.KsqlDataSourceSchema",
  "name": "KsqlDataSourceSchema",
  "namespace": "io.confluent.ksql.avro_schemas",
  "type": "record",
  "fields": [
    {
      "default": null,
      "name": "ORDER_KEY",
      "type": [
        "null",
        "string"
      ]
    },
    {
      "default": null,
      "name": "RETRY_REDIRECT_FLAG",
      "type": [
        "null",
        "string"
      ]
    },
    {
      "default": null,
      "name": "REVISION_NUMBER",
      "type": [
        "null",
        "string"
      ]
    },
    {
      "default": null,
      "name": "REDIRECT_LOCK",
      "type": [
        "null",
        "int"
      ]
    },
    {
      "default": null,
      "name": "ORDER_PAYLOAD",
      "type": [
        "null",
        "string"
      ]
    }
  ]
}

• 在Control Center的ksqlDB中执行创建Stream的语句：

CREATE STREAM my_stream
  WITH (KAFKA_TOPIC='my_topic', VALUE_FORMAT='AVRO');

• 检查所有资源配置均无异常；
• 尝试向Topic发送事件并期望在Stream中展示：
  • 打开新窗口执行监听语句：

  SELECT * FROM my_stream EMIT CHANGES;
  

  • 在Control Center的Topic消息视图中发送如下事件：

  {"order_key":"1234-ABC-1002003001","retry_redirect_flag":"RETRY","revision_number":"000","redirect_lock":1,"order_payload":"buy fund-a 3000 shares"}
  

  • 但Stream监听窗口始终无数据展示。

额外测试情况：按照Confluent官方指南测试pageviewsTopic和Stream时，通过Datagen Connector生成的数据能被Stream正常展示，但手动发送的事件无法被加载。

内容的提问来源于stack exchange，提问作者Brian N.