SAP ABAP程序如何读取kafka主题消息?

由于项目需要,需要SAP通读取kafka中的主题消息。
现需求通过编写ABAP程序,读取kafka中的主题消息,进行逻辑计算。
网上查找了很多,相关的资料很少。
不知道谁有做过类似的项目或者有相关的资料?

SAP ABAP 程序读取 Kafka 主题消息的步骤如下:

在 SAP ABAP 环境中安装并配置 Apache Kafka 客户端库。

通过使用 ABAP 程序中的 Apache Kafka 客户端库函数,连接到指定的 Kafka 集群。

订阅需要读取的 Kafka 主题消息。

使用 Apache Kafka 客户端库函数,从主题读取消息。

在 ABAP 程序中进行逻辑计算处理。

关闭与 Kafka 集群的连接。

ABAP程序:

*&---------------------------------------------------------------------*
*& Report ZKAFKA_READ
*&---------------------------------------------------------------------*
*&
*&---------------------------------------------------------------------*
*&
*&
*&---------------------------------------------------------------------*

REPORT zkafka_read.

DATA: lv_topic TYPE string,
      lv_message TYPE string.

START-OF-SELECTION.

  CALL FUNCTION 'KAFKA_READ'
    EXPORTING
      topic     = lv_topic
    IMPORTING
      message   = lv_message.

  IF lv_message IS NOT INITIAL.
    CALL FUNCTION 'KAFKA_PROCESS'
      EXPORTING
        message   = lv_message.
  ENDIF.

END-OF-SELECTION.