Specifying Kafka Scheduler Options

The database uses an event consumer, the Kafka scheduler, to ingest events from Transformation Hub's Kafka component. To obtain the event schema from Transformation Hub's Schema Registry component, Kafka scheduler uses the schema registry server setting. When you modify the schema registry settings, you affect Kafka scheduler. Thus, you must stop and delete the scheduler, make your changes to the registry, then create the scheduler again.  

To manage Kafka scheduler, enter ./kafka_scheduler <Option_Name> where you include any of the following options:

Option Name

Description

update

Updates the scheduler

start

Starts the scheduler and begins copying data from all registered Kafka brokers

stop

Stops the scheduler and ends copying data from all registered Kafka brokers

delete

Deletes all registered Kafka instances from the scheduler

status

Prints the following information and log status for a running or stopped scheduler:

  • Current Kafka cluster assigned to the scheduler
  • Name and database host where the active scheduler is running
  • Name, database host, and process ID of every running scheduler (active or backup)
events

Prints event copy progress for the scheduler

messages Prints scheduler messages