source-http

CREATE SOURCE CONNECTOR http_source WITH (
  'http.request.headers' = 'Content-Type: application/json',
  'http.request.url' = 'http://demo:demo@public-ipv4:8080/engine-rest/history/activity-instance/',
  'http.throttler.interval.millis' = '30000',
  'http.request.method' = 'GET',
  'kafka.topic' = 'act_hi_taskinst',
  'http.throttler.catchup.interval.millis' = '1000',
  'connector.class' = 'com.github.castorm.kafka.connect.http.HttpSourceConnector',
  'tasks.max' = '1',
  'key.converter' ='org.apache.kafka.connect.storage.StringConverter',
  'value.converter' = 'org.apache.kafka.connect.json.JsonConverter',
  'header.converter' = 'org.apache.kafka.connect.json.JsonConverter',
  'errors.log.enable' = 'true',
  'errors.log.include.messages' = 'true',
  'schema.generation.enabled' = 'true',
  'mode' = 'incrementing'
);