sarama
-
Kafka Golang 예제Language/Golang 2023. 2. 12. 14:38
Example For Sarama call_topic 이라는 이름을 가진 Topic 에 Partition 0 번에 Event를 전달하는 예시 // ProducerTest package main import ( "fmt" "time" "github.com/Shopify/sarama" ) //Reference : https://pkg.go.dev/github.com/shopify/sarama func SyncWriter(brokerList []string) sarama.SyncProducer { // For the data collector, we are looking for strong consistency semantics. // Because we don't change the flush setting..