To connect Kafka in Go, you need to use Kafka's Go client library, such as sarama. sarama is a pure Go implementation Kafka client library that provides functions such as connecting to Kafka clusters, sending and receiving messages.
Here is a basic Kafka connection example:
package main
import (
"fmt"
"log"
"/Shopify/sarama"
)
func main() {
// Create a Kafka configuration instance config := ()
// Set up a consumer group = 10 *
= 3 *
// Create a Kafka consumer instance consumer, err := ([]string{"localhost:9092"}, config)
if err != nil {
("Failed to create consumer: %s", err)
}
defer func() {
if err := (); err != nil {
("Failed to close consumer: %s", err)
}
}()
// Create a Kafka producer instance producer, err := ([]string{"localhost:9092"}, config)
if err != nil {
("Failed to create producer: %s", err)
}
defer func() {
if err := (); err != nil {
("Failed to close producer: %s", err)
}
}()
// Send a message to Kafka () <- &{
Topic: "my-topic",
Value: ("Hello, Kafka!"),
}
// Consume messages from Kafka partitionConsumer, err := ("my-topic", 0, )
if err != nil {
("Failed to create partition consumer: %s", err)
}
defer func() {
if err := (); err != nil {
("Failed to close partition consumer: %s", err)
}
}()
for msg := range () {
("Received message: %s\n", string())
}
}This example demonstrates how to create Kafka consumer and producer instances, send and receive messages. You need to replace the address and port number of the Kafka server with the actual value and set Kafka configuration options to suit your needs. You also need to introduce a sarama library in your code, such as using go mod to manage dependencies.
Note that this is just a basic example and may need to be modified and extended according to your actual needs. For example, you may need to handle connection errors, serializing/deserializing messages, using Kafka's transactional capabilities, and more.
This is the article about the implementation example of Go-connected kafka. For more related Go-connected kafka content, please search for my previous articles or continue browsing the related articles below. I hope everyone will support me in the future!