Apache Kafkaでシリアライザを指定する必要があるのはなぜですか？

Question

私はこの疑問をthis questionから得ました。

私がKafkaストリームを使用していないとき、なぜZkClientを作成するときにシリアライザを使用する必要がありますか？

Answer 1

Kafka havilyは、メタデータ（トピック）を格納するために飼育係を使用しています。そのライブラリcom.101tec :: zkClientが使用されます。ソースコードZkClientによると、zookeeperから送信/受信されたデータのシリアライズ/デシリアライズにはZkSerializerが必要です。 Kafkaの内部には、ZkSerializer：ZKStringSerializer（zkUtilsで定義されています）の実装があります。

しかし、カフカ（生産/消費）との通常のやり取りでは、ZkClientを作成する必要はありません。それは「管理」作業にのみ必要です。