DROP PROCEDURE SQDR.TOKAFKA;
CREATE PROCEDURE SQDR.TOKAFKA 
( IN groupId CHAR (16) FOR BIT DATA, IN subscriptionId CHAR (16) FOR BIT DATA, IN resyncState CHAR(1), IN transaction_id CHAR (10)
FOR BIT DATA, IN changeRowCounter BIGINT, IN changeRowSequence BIGINT, IN changeRowLogDetail VARCHAR(512), 
IN change_row_member VARCHAR(10), IN changeRowTimestamp TIMESTAMP, IN changeRowNanosecond INTEGER, IN changeRowType CHAR(1), 
IN actionTaken CHAR(1), IN resultRowCount INTEGER, IN flaggedCount BIGINT, IN keylogTs TIMESTAMP, 
IN resultError CLOB(64K), IN beforeKey CLOB(64K), IN beforeKeyEdited CLOB(64K), IN afterKey CLOB(64K), IN afterKeyEdited CLOB(64K), 
IN afterImage CLOB(64K) ) 
NOT DETERMINISTIC 
LANGUAGE Java 
EXTERNAL NAME 'KAFKAPROCS_JAR:com.starquest.udb.kafka.KafkaProcedure.TOKAFKA' 
FENCED PARAMETER STYLE JAVA;