Teradata Access Module for Kafkaでは、0.8.x.y以降のすべてのバージョンのApache Kafkaサーバーをサポートしています。
0.9.0.xよりも前のバージョンのKafkaサーバーの場合、初期化文字列に以下を追加する必要があります。
"-X api.version.request=false -X broker.version.fallback=a.b.c.d"
ここでa.b.c.dは、ブローカーの実際のバージョンを表わします。
Teradata Access Module for Kafkaでは、0.8.x.y以降のすべてのバージョンのApache Kafkaサーバーをサポートしています。
0.9.0.xよりも前のバージョンのKafkaサーバーの場合、初期化文字列に以下を追加する必要があります。
"-X api.version.request=false -X broker.version.fallback=a.b.c.d"
ここでa.b.c.dは、ブローカーの実際のバージョンを表わします。