A example to consume kafka message with golang and confluent. package main import ( "log" "github.com/confluentinc/confluent-kafka-go/kafka" ) func main() { c, err := kafka.NewConsumer(&kafka.ConfigMap{ "bootstrap.servers": "localhost:9092", "group.id": "myGroupId", }) if err != nil { panic(err) } c.SubscribeTopics([]string{"quick-start-event"}, nil) for { msg, err := c.ReadMessage(-1) if err == n
Apache Kafka Meetup Japan #9 登壇資料
リリース、障害情報などのサービスのお知らせ
最新の人気エントリーの配信
処理を実行中です
j次のブックマーク
k前のブックマーク
lあとで読む
eコメント一覧を開く
oページを開く