Skip to content

cloudstark/kafka-connect-jdbc

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

10 Commits
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 

Repository files navigation

kafka-connect-jdbc

Build Status License

kafka-connect-jdbc is a plugin of Apache Kafka Connect.

  docker run --rm \
    -e "CONNECT_BOOTSTRAP_SERVERS=...:9092" \
    -e "CONNECT_GROUP_ID=connect-jdbc" \
    -e "CONNECT_CONFIG_STORAGE_TOPIC=connect-jdbc-config" \
    -e "CONNECT_CONFIG_STORAGE_REPLICATION_FACTOR=1" \
    -e "CONNECT_OFFSET_STORAGE_TOPIC=connect-jdbc-offset" \
    -e "CONNECT_OFFSET_STORAGE_REPLICATION_FACTOR=1" \
    -e "CONNECT_STATUS_STORAGE_TOPIC=connect-jdbc-status" \
    -e "CONNECT_STATUS_STORAGE_REPLICATION_FACTOR=1" \
    -e "CONNECT_KEY_CONVERTER=org.apache.kafka.connect.json.JsonConverter" \
    -e "CONNECT_VALUE_CONVERTER=org.apache.kafka.connect.json.JsonConverter" \
    -e "CONNECT_INTERNAL_KEY_CONVERTER=org.apache.kafka.connect.json.JsonConverter" \
    -e "CONNECT_INTERNAL_VALUE_CONVERTER=org.apache.kafka.connect.json.JsonConverter" \
    -e "CONNECT_REST_ADVERTISED_HOST_NAME=..." \
    -e "CONNECT_REST_PORT=8083" \
    -e "SECRETS_PROVIDER=env" \
    -e "CONNECTOR_NAME=connect-jdbc" \
    -e "CONNECTOR_CONNECTOR_CLASS=io.confluent.connect.jdbc.JdbcSourceConnector" \
    -e "CONNECTOR_TASKS_MAX=1" \
    -e "CONNECTOR_CONNECTION_URL=jdbc:postgresql://...:5432/postgres" \
    -e "CONNECTOR_CONNECTION_USER=postgres" \
    -e "CONNECTOR_CONNECTION_PASSWORD=postgres" \
    -e "CONNECTOR_DIALECT_NAME=PostgreSqlDatabaseDialect" \
    -e "CONNECTOR_TOPIC_PREFIX=demo" \
    -e "CONNECTOR_MODE=bulk" \
    -e "CONNECTOR_QUERY=SELECT * FROM demo" \
    kafka-connect-jdbc

License

FOSSA Status