KAFKA と Spring を統合しようとしています。私の Java アプリケーションは KAFKA サーバーと通信しており、HTTP を使用してアプリケーションを実行するとメッセージも受信しています。
ここで、Spring を使用して KAFKA に SSL を追加したいと思います。SSL KAFKAおよびSPRING KAFKAで指定された変更を行いました。
コマンド ラインを使用して (SSL を使用して) プロデューサーとコンシューマーを実行すると、通信は適切に行われますが、Java アプリケーションの構成を変更し、トピックでメッセージを生成および消費しようとすると、コンシューマーは正常に動作し、メッセージを取得しています。指定されたトピック。
しかし、プロデューサーは期待どおりに動作していません。JAVA アプリケーション プロデューサーから送信されたメッセージがコンシューマーで受信されません (コマンド ラインでも Java アプリ コンシューマーでもありません)。
私はそれをグーグルで検索しましたが、それに対する答えが見つかりませんでした。ポインタはありますか？
PS: KAFKA バージョン kafka 0.9.0.0、JAVA 7、および Spring で使用される SSL プロパティは次のとおりです。
<prop key="ssl.keystore.location">/keystore.jks</prop>
<prop key="ssl.keystore.password">password</prop>
<prop key="ssl.key.password">password</prop>
<prop key="security.protocol">SSL</prop>
<prop key="ssl.truststore.location">/truststore.jks</prop>
<prop key="ssl.truststore.password">password</prop>