Skip to content

Commit

Permalink
Correct the location (#844)
Browse files Browse the repository at this point in the history
Signed-off-by: clyang82 <[email protected]>
  • Loading branch information
clyang82 authored Feb 16, 2023
1 parent 376e195 commit 4cbabea
Show file tree
Hide file tree
Showing 3 changed files with 4 additions and 4 deletions.
4 changes: 2 additions & 2 deletions samples/kafka/message-handle-non-cloudevents/main.go
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@ import (
"github.com/cloudevents/sdk-go/v2/binding"
)

// In order to run this test, look at documentation in https://github.com/cloudevents/sdk-go/blob/master/v2/samples/kafka/README.md
// In order to run this test, look at documentation in https://github.com/cloudevents/sdk-go/blob/main/samples/kafka/README.md
func main() {
saramaConfig := sarama.NewConfig()
saramaConfig.Version = sarama.V2_0_0_0
Expand Down Expand Up @@ -64,7 +64,7 @@ func main() {
event.SetID(uuid.New().String())
event.SetTime(time.Now())
event.SetType("generated.examples")
event.SetSource("https://github.com/cloudevents/sdk-go/v2/samples/kafka/sender")
event.SetSource("https://github.com/cloudevents/sdk-go/samples/kafka/message-handle-non-cloudevents")

err = event.SetData(kafkaMessage.ContentType, kafkaMessage.Value)
if err != nil {
Expand Down
2 changes: 1 addition & 1 deletion samples/kafka/sender-receiver/main.go
Original file line number Diff line number Diff line change
Expand Up @@ -62,7 +62,7 @@ func main() {
for i := 0; i < count; i++ {
e := cloudevents.NewEvent()
e.SetType("com.cloudevents.sample.sent")
e.SetSource("https://github.com/cloudevents/sdk-go/v2/samples/httpb/requester")
e.SetSource("https://github.com/cloudevents/sdk-go/samples/kafka/sender-receiver")
_ = e.SetData(cloudevents.ApplicationJSON, map[string]interface{}{
"id": i,
"message": "Hello, World!",
Expand Down
2 changes: 1 addition & 1 deletion samples/kafka/sender/main.go
Original file line number Diff line number Diff line change
Expand Up @@ -40,7 +40,7 @@ func main() {
e := cloudevents.NewEvent()
e.SetID(uuid.New().String())
e.SetType("com.cloudevents.sample.sent")
e.SetSource("https://github.com/cloudevents/sdk-go/v2/samples/kafka/sender")
e.SetSource("https://github.com/cloudevents/sdk-go/samples/kafka/sender")
_ = e.SetData(cloudevents.ApplicationJSON, map[string]interface{}{
"id": i,
"message": "Hello, World!",
Expand Down

0 comments on commit 4cbabea

Please sign in to comment.