Skip to content
This repository has been archived by the owner on Dec 15, 2021. It is now read-only.

Commit

Permalink
Merge pull request #223 from sebgoa/tmpkafka
Browse files Browse the repository at this point in the history
write in a directory where I can write
  • Loading branch information
sebgoa authored Jul 25, 2017
2 parents 8c2501b + 31994cd commit e9208af
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions cmd/kubeless/topicPublish.go
Original file line number Diff line number Diff line change
Expand Up @@ -43,11 +43,11 @@ var topicPublishCmd = &cobra.Command{
logrus.Fatal(err)
}

body := fmt.Sprintf(`echo %s > msg.txt`, data)
body := fmt.Sprintf(`echo %s > /tmp/msg.txt`, data)
command := []string{"bash", "-c", body}
execCommand(command, ctlNamespace)

body = fmt.Sprintf(`/opt/bitnami/kafka/bin/kafka-console-producer.sh --broker-list localhost:9092 --topic %s < msg.txt`, topic)
body = fmt.Sprintf(`/opt/bitnami/kafka/bin/kafka-console-producer.sh --broker-list localhost:9092 --topic %s < /tmp/msg.txt`, topic)
command = []string{"bash", "-c", body}
execCommand(command, ctlNamespace)
},
Expand Down

0 comments on commit e9208af

Please sign in to comment.