2.4.12 既存のKafkaビューの再構成

Oracle SQL access to Kafka (OSaK)ビューによる処理中のトピックに、さらにKafkaパーティションを追加できます。OSaKでは、既存の一連のOSaKビューにKafkaパーティションをさらに追加する、ORA_KAFKA.CREATE_VIEWSに似たプロシージャが用意されています。

ORA_KAFKA.ADD_PARTITIONSプロシージャは、既存のKafkaトピック・パーティションに関する状態情報を保持し、新規パーティションを既存のビューまたは新規ビューバインドします。

次の例では、ORA_KAFKA.ADD_PARTITIONSプロシージャをコールして、MA1クラスタ用にすでに作成されているビューに、新しいKafkaパーティションを追加します。

DECLARE
  views_created INTEGER;
  application_id VARCHAR2(128);
BEGIN
  ORA_KAFKA.ADD_PARTITIONS
    ('MA1',           -- The name of the cluster (specified in ORA_KAFKA.REGISTER_CLUSTER)
    'QUERYAPP',       -- The name given by the user for a set of views, corresponds to the concept of a Kafka group
    'sensor',         -- The name of the Kafka topic
    views_created);   -- Output: number of views created.  -1 is returned if there are no additional partitions
                      -- since the views were created or since the last call to ORA_KAFKA.ADD_PARTITIONS

  dbms_output.put_line(‘views created = ‘ || views_created);
END;
/