We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 3e39ac1 commit 4be52abCopy full SHA for 4be52ab
internal/timeline/kafka.go
@@ -133,9 +133,9 @@ func (m kafkaClient) ChangeEpisodeStatus(
133
func (m kafkaClient) writeMessage(ctx context.Context, uid model.UserID, value timelineValue) error {
134
err := m.kafka.WriteMessages(ctx, kafka.Message{
135
Topic: timelineTopic,
136
- Key: []byte(fmt.Sprintf("%d", uid)),
+ Key: fmt.Appendf(nil, "%d", uid),
137
Value: lo.Must(json.Marshal(value)),
138
})
139
140
- return errgo.Wrap(err, "grpc")
+ return errgo.Wrap(err, "kafka")
141
}
0 commit comments