Apache Kafka Logger Topics

On this page

Topic grid

Topic form

Execute script option

This option allows custom javascript code execution.

For example this script will execute Advanced ETL Processor package

const execFileSync = require("child_process").execFileSync;
try {
  // This script might hung so always specify a timeout
  const fileToExecute = '"C:\\Program Files (x86)\\DB Software Laboratory\\Advanced ETL Processor Enterprise\\aetlcl.exe"';
  const objectId = 6687;
  const parameters = [objectId];
  const timeout = 60; //seconds
  const stdout = execFileSync(fileToExecute, parameters, { shell: true, timeout: timeout * 1000 });
} catch (e) {
  logger.error(e.message);
  return 500;
}
return 200;

Printing meta data

logger.debug(logId);
logger.debug(connectionId);
logger.debug(connectionName);
logger.debug(topicId);
logger.debug(topic);
logger.debug(messageKey);
logger.debug(messageValue);
logger.debug(messageOffset);
logger.debug(messagePartition);
logger.debug(messageHighWaterOffset);