Source: zaynkorai.medium.com
Apache Kafka with Golang
Before this I have worked with Apache Kafka as DevOps Engineer. It got me curious to learn about it that how to decrease high latency of systems and Increase response time even during traffic spikes or high volume data?
PS: This is just my learning experience here.Where I will only write about simple producer and consumer programs using Go and Apache Kafka. Apache Kafka is an open-source distributed event streaming platform used by thousands of companies for high-performance data pipelines, streaming analytics, data integration, and mission-critical applications.
Connect to Apache Kafka using sarama as ProducerPush a Comment to queue(topic) using saramaThis function is realy simple it’s takes topic and message as parameters, makes a connection to kafka using the function ConnectProducer above and push that message on given topic.
PS: This is just my learning experience here.Where I will only write about simple producer and consumer programs using Go and Apache Kafka. Apache Kafka is an open-source distributed event streaming platform used by thousands of companies for high-performance data pipelines, streaming analytics, data integration, and mission-critical applications.
Connect to Apache Kafka using sarama as ProducerPush a Comment to queue(topic) using saramaThis function is realy simple it’s takes topic and message as parameters, makes a connection to kafka using the function ConnectProducer above and push that message on given topic.
Related Articles
Community Partners
DevOps Careers