Test sources fixes for kafka 0.8