updated kafka protocol for recent changes (#140)

1 file changed