2

私はカフカコミュニティに不慣れで、難しい質問に直面しています。本文がjsonメッセージであるRest Webサービスを介して互いに通信する2つのアプリケーションがあります。

これら 2 つのアプリケーションの間のミドルウェアとして kafka を使用し、アプリケーションへの影響を最小限またはゼロにするにはどうすればよいですか?

これは私の現状のシナリオです:

https://i.imgur.com/i4yoFHd.png

私の将来のシナリオ:

https://i.imgur.com/z05ceQj.png

ヘッダーとボディを変換するために STM またはインターセプターを使用することを考えました。

そのようにすることは可能ですか？私は体を次のように変換しなければならないことを知っています:

      {
        "first name" : "Donald" ,
        "last name" : "Trump"
      },
      {
        "first name" : "Vladimir" ,
        "last name" : "Putin"
      }

に：

{
  "records":
  [
    {
      "key": "K001",
      "value":
      {
        "first name" : "Donald" ,
        "last name" : "Trump"
      }
    },
    {
      "key": "K002",
      "value":
      {
        "first name" : "Vladimir" ,
        "last name" : "Putin"
        }
    }
  ]
}

基本的に、私の変換は、各レコードのフィールドではなく、メッセージの最初と最後を変更します。

誰かがそのようなことをしたことがありますか、または私がどちらに行くべきかの兆候がありますか?

4

2 に答える 2