Add Kafka Input and Output plugins

`SimpleT` is just a hack to work around the fact that gospec doesn't pass Go's *testing.T into the spec code, but gomock needs it. You can get rid of this and just use the `t` variable that your test is handed.