Sviluppo di un processore operazione personalizzato Kafka definito dall'utente (UNIX e Linux)

Puoi creare un KCOP (custom operation processor) Kafka che funziona con CDC Replication Engine for Kafka su Linux® e UNIX sviluppando una classe Java™ .

Informazioni su questa attività

Puoi modificare i KCOP integrati forniti con CDC Replication Engine for Kafka per adattarli alle tue necessità oppure utilizzarli come esempi per creare KCOP definiti dall'utente. Un KCOP deve implementare l'interfaccia KafkaCustomOperationProcessorIF. Per ulteriori informazioni sull'interfaccia, consultare il riferimento all'API in formato Javadoc installato con CDC Replication Engine for Kafka.

Procedura

  1. Estrai il file samples.jar nella directory lib nella tua directory di installazione di Kafka CDC. 
    $ cd CDC_Kafka_installation_directory/lib
$ jar xf ../samples/samples.jar
    I KCOP integrati sono in CDC_Kafka_installation_directory/lib/com/datamirror/ts/target/publication/userexit/sample/kafka
  2. Trova un KCOP da utilizzare come esempio. Ridenominare la classe e il file .java in modo che non corrispondano a nessuno dei file .java KCOP integrati.
  3. Modificare il file .java .
  4. Compilare il file KCOP .java definito dall'utente utilizzando IBM® SDK, Java Technology Edition, Versione 8.
    $ javac -classpath "CDC_Kafka_installation_directory/lib/*"
CDC_Kafka_installation_directory/lib/com/datamirror/ts/target/publication/userexit/sample/kafka/user-defined_KCOP.java
  5. Confermare che un file .class sia stato creato nella stessa directory in cui risiede il file .java KCOP definito dall'utente.
    $ cd CDC_Kafka_installation_directory/lib/com/datamirror/ts/target/publication/userexit/sample/kafka
    Nota: i file generati dalla compilazione della classe devono trovarsi in una libreria o cartella a cui fa riferimento la variabile di ambiente CLASSPATH.
  6. Arrestare l'archivio dati CDC Replication Engine for Kafka .
  7. Avviare il datastore CDC Replication Engine per Kafka .
  8. Segui i passi da 1 a 6 da Enabling integrated Kafka custom operation processor (KCOP).
  9. Immettere i valori per i seguenti campi:
    Nome classe
    com.datamirror.ts.target.publication.userexit.sample.kafka.KCOP definito dall'utente
    Parametri
    I parametri sono determinati dal KCOP definito dall'utente.
  10. Fare clic su OK.
    Nota: l'aggiunta di librerie alla variabile CLASSPATH in conflitto con le librerie fornite con CDC Replication Engine for Kafka non è supportata.