Skip to content
Permalink
Browse files
[hotfix] cleanup golang showcase
  • Loading branch information
sjwiesman committed Aug 27, 2021
1 parent f096174 commit 34921803a9de3f67e5a2f6f981a41d781fd74283
Showing 2 changed files with 2 additions and 2 deletions.
@@ -42,7 +42,7 @@ func EgressFn(ctx statefun.Context, _ statefun.Message) error {
ctx.SendEgress(statefun.KinesisEgressBuilder{
Target: KinesisEgressTypeName,
Stream: "my-kinesis-stream",
Value: "hello world again!",
Value: []byte("hello world again!"),
PartitionKey: "my-partition-key",
ExplicitHashKey: "my-explicit-hash-key",
})
@@ -45,7 +45,7 @@ func greetings(ctx statefun.Context, message statefun.Message) error {
Target: KafkaEgress,
Topic: "greetings",
Key: ctx.Self().Id,
Value: greeting,
Value: []byte(greeting),
})

return nil

0 comments on commit 3492180

Please sign in to comment.