diff --git a/go/src/basic_producer/BasicProducer.go b/go/src/basic_producer/BasicProducer.go new file mode 100644 index 0000000000000000000000000000000000000000..f5383983788e76b5550751068762f7a48553ce5b --- /dev/null +++ b/go/src/basic_producer/BasicProducer.go @@ -0,0 +1,38 @@ +package main + +import ( + "context" + "fmt" + + kafka "github.com/segmentio/kafka-go" +) + +func getKafkaWriter(kafkaURL, topic string) *kafka.Writer { + return &kafka.Writer{ + Addr: kafka.TCP(kafkaURL), + Topic: topic, + Balancer: &kafka.LeastBytes{}, + } +} + +func main() { + // get kafka writer using environment variables. + kafkaURL := "localhost:9092" + topic := "first-topic" + kafkaWriter := getKafkaWriter(kafkaURL, topic) + + defer kafkaWriter.Close() + + // Send messages. + for _, word := range []string{"Welcome", "gokafka"} { + msg := kafka.Message{ + Key: []byte(fmt.Sprintf("Key-%d", 1)), + Value: []byte(word), + } + + err := kafkaWriter.WriteMessages(context.Background(), msg) + if err != nil { + fmt.Println(err) + } + } +} diff --git a/python/src/AjouSlackProducer.py b/python/src/AjouSlackProducer.py index de7970d34a94e9b137f0f172e5da9dd1e6d8c83f..c1b242c48cef6b3d10ce296aac074bf41cfe6000 100644 --- a/python/src/AjouSlackProducer.py +++ b/python/src/AjouSlackProducer.py @@ -17,7 +17,7 @@ def acked(err, msg): if err is not None: print("Failed to deliver message: {0}: {1}".format(msg.value(), err.str())) else: - print(f"Message produced: {0}...".format(msg.value())) + print("Message produced: {0}...".format(msg.value())) # Make data into dictionary format