[FLINK-16398] [kafka] Change all Kafka type strings in tests files accordingly

This closes #48.
6 files changed