fix(kafka-pubsub): restore pb.state appropriately (#11135)
#196
| Job | Run time |
|---|---|
| 42s | |
| 42s |
pb.state appropriately (#11135)
#196
| Job | Run time |
|---|---|
| 42s | |
| 42s |