sink-http

CREATE SOURCE CONNECTOR http WITH (
    'topics' = 'process_logpickr',
    'tasks.max' = '1',
    'connector.class' = 'io.confluent.connect.http.HttpSinkConnector',
    'http.api.url' = 'http://public-ipv4:8888',
    'key.converter' = 'org.apache.kafka.connect.storage.StringConverter',
    'header.converter' = 'org.apache.kafka.connect.storage.StringConverter',
    'value.converter' = 'org.apache.kafka.connect.storage.StringConverter',
    'confluent.topic.bootstrap.servers' =  'broker:29092',
    'confluent.topic.replication.factor' = '1',
    'reporter.bootstrap.servers' = 'broker:29092',
    'reporter.error.topic.replication.factor' = '1',
    'reporter.result.topic.replication.factor' = '1'
        );