Make example plugin work for all topics in dev/gen

cswank · Jan 22, 2019 · c9d0944 · c9d0944
1 parent 2aef792
commit c9d0944
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/examples/plugin/protobuf.go b/examples/plugin/protobuf.go
@@ -14,6 +14,10 @@ import (
 type Protobuf struct{}
 
 func (p Protobuf) Decode(topic string, b []byte) ([]byte, error) {
+	if topic != "proto" {
+		return b, nil
+	}
+
 	var x person.Person
 	err := proto.Unmarshal(b, &x)
 	if err != nil {