COCO Kafka Bridge

Kafka consumer listening to kafka-proxy and forwarding messages to another KAFKA-PROXY or a simple HTTP endpoint

Set the following environment variables:

$QUEUE_PROXY_ADDRS
$GROUP_ID
$CONSUMER_OFFSET (default largest)
$CONSUMER_AUTOCOMMIT_ENABLE (enable autocommit when consuming from kafka proxy - use true for smaller, false for larger messages)
$AUTHORIZATION_KEY
$TOPIC
$PRODUCER_ADDRESS
$PRODUCER_AUTH
$PRODUCER_TYPE (possible values: proxy or plainHTTP)
$SERVICE_NAME

Name		Name	Last commit message	Last commit date
Latest commit History 501 Commits
.circleci		.circleci
.github		.github
helm/coco-kafka-bridge		helm/coco-kafka-bridge
runbooks		runbooks
.gitignore		.gitignore
Dockerfile		Dockerfile
Jenkinsfile		Jenkinsfile
README.md		README.md
go.mod		go.mod
go.sum		go.sum
healthchecks.go		healthchecks.go
healthchecks_test.go		healthchecks_test.go
kafka-bridge.go		kafka-bridge.go
message_consumer.go		message_consumer.go
message_forwarder.go		message_forwarder.go
message_forwarder_test.go		message_forwarder_test.go
plain_http_producer.go		plain_http_producer.go
plain_http_producer_test.go		plain_http_producer_test.go