/accs-go-kafka-mysql

Example for Go based Kafka consumer pushing data to MySQL (all on Oracle Cloud)

Primary LanguageGoGNU General Public License v3.0GPL-3.0

Build

  • git clone https://github.com/abhirockzz/accs-go-kafka-mysql.git
  • cd accs-go-kafka-mysql
  • zip accs-go-kafka-mysql.zip gokafkamysql.go start.sh

Run locally

  • Make sure Kafka and MySQL are ready (locally or in the cloud)
  • set the following environment variables - MYSQLCS_USER_NAME, MYSQLCS_USER_PASSWORD, MYSQLCS_CONNECT_STRING (format <host>:<port>/<dbName>), OEHCS_EXTERNAL_CONNECT_STRING (<host>:<port>) and OEHCS_TOPIC (Kafka topic)
  • go get github.com/bsm/sarama-cluster
  • go get github.com/go-sql-driver/mysql
  • go run gokafkamysql.go

Deploy to Oracle Application Container Cloud & test the app

Check out the blog - 'Go' for Kafka on Oracle Cloud