{"id":46725,"date":"2023-12-09T21:24:16","date_gmt":"2023-03-10T15:32:50","guid":{"rendered":"https:\/\/www.silicloud.com\/zh\/blog\/46725-2\/"},"modified":"2024-05-04T12:52:09","modified_gmt":"2024-05-04T04:52:09","slug":"46725-2","status":"publish","type":"post","link":"https:\/\/www.silicloud.com\/zh\/blog\/46725-2\/","title":{"rendered":""},"content":{"rendered":"

\u306f\u3058\u3081\u306b<\/h1>\n

NestJS\u306e\u30d5\u30ec\u30fc\u30e0\u30ef\u30fc\u30af\u306e\u6069\u6075\u3082\u53d7\u3051\u3064\u3064\u3082\u30a4\u30d9\u30f3\u30c8\u99c6\u52d5\u306a\u975e\u540c\u671f\u30a2\u30d7\u30ea\u30b1\u30fc\u30b7\u30e7\u30f3\u3092\u4f5c\u308a\u305f\u3044\uff01\u3068\u3044\u3046\u65b9\u3082\u591a\u3044\u3093\u3058\u3083\u306a\u3044\u3067\u3057\u3087\u3046\u304b\u3002
\n\u4eca\u56de\u306fNestJS\u3068kafkajs\u3092\u7d44\u307f\u5408\u308f\u305b\u305fKafkaConsumer\u306e\u5b9f\u88c5\u3092\u7d39\u4ecb\u3057\u3066\u3044\u304d\u307e\u3059\u3002<\/p>\n

Apache Kafka\u3068\u306f<\/h1>\n
\"\u30b9\u30af\u30ea\u30fc\u30f3\u30b7\u30e7\u30c3\u30c8<\/div>\n

\u30aa\u30fc\u30d7\u30f3\u30bd\u30fc\u30b9\u306e\u5206\u6563\u30b9\u30c8\u30ea\u30fc\u30df\u30f3\u30b0\u9001\u53d7\u4fe1\u51e6\u7406\u57fa\u76e4\u3067\u3001\u30a4\u30d9\u30f3\u30c8\u99c6\u52d5\u30b7\u30b9\u30c6\u30e0\u306e\u30e1\u30c3\u30bb\u30fc\u30b8\u30d6\u30ed\u30fc\u30ab\u30fc\u3068\u3057\u3066\u3082\u3088\u304f\u5229\u7528\u3055\u308c\u3066\u3044\u307e\u3059\u3002
\nKafka\u306e\u4ed5\u7d44\u307f\u306b\u3064\u3044\u3066\u306f\u65e5\u7acb\u88fd\u4f5c\u6240\u304c\u51fa\u3057\u3066\u3044\u308b\u4e0b\u8a18\u8a18\u4e8b\u3084CONFLUENT\u304c\u51fa\u3057\u3066\u308b\u958b\u767a\u8005\u30ac\u30a4\u30c9\u304c\u308f\u304b\u308a\u3084\u3059\u3044\u305f\u3081\u4e00\u8aad\u3055\u308c\u308b\u3053\u3068\u3092\u30aa\u30b9\u30b9\u30e1\u3057\u307e\u3059\u3002
\nApache Kafka\u306e\u6982\u8981\u3068\u30a2\u30fc\u30ad\u30c6\u30af\u30c1\u30e3
\nCONFLUENT Introduction to Kafka<\/p>\n

kafkajs\u3068\u306f<\/h1>\n
\"kafka-node_kafkajs\u6bd4\u8f03.png\"<\/div>\n

NestJS\u306e\u30de\u30a4\u30af\u30ed\u30b5\u30fc\u30d3\u30b9\u30b5\u30dd\u30fc\u30c8\u6a5f\u80fd\u306b\u3064\u3044\u3066<\/h1>\n

NestJS\u306e@nestjs\/microservices\u30d1\u30c3\u30b1\u30fc\u30b8\u3092\u5229\u7528\u3059\u308b\u3068
\nMQTT\/Kafka\/RabbitMQ\/gRPC\u306a\u3069\u69d8\u3005\u306a\u30df\u30c9\u30eb\u30a6\u30a7\u30a2\u306b\u5bfe\u5fdc\u3057\u305f\u30b7\u30b9\u30c6\u30e0\u3092\u69cb\u7bc9\u3067\u304d\u307e\u3059\u3002
\n\u7b46\u8005\u3082\u6700\u521d\u306f\u672c\u6a5f\u80fd\u3092\u5229\u7528\u3057\u3066\u958b\u767a\u3092\u3057\u3066\u3044\u305f\u306e\u3067\u3059\u304c\u30011\u30c8\u30d4\u30c3\u30af\u8907\u6570Consumer\u3092\u52d5\u304b\u3059
\n\u30e6\u30fc\u30b9\u30b1\u30fc\u30b9\u3067\u8a66\u3057\u3066\u307f\u305f\u969b\u306b\u30011\u30c8\u30d4\u30c3\u30af1Consumer\u306e\u5236\u7d04\u304b\u3089\u3069\u3046\u3057\u3066\u3082\u8131\u5374\u3067\u304d\u305a
\n\u30d5\u30ec\u30fc\u30e0\u30ef\u30fc\u30af\u306e\u72ec\u81ea\u306e\u4ed5\u69d8\u306b\u56fa\u304f\u7e1b\u3089\u308c\u3066\u3057\u307e\u3063\u305f\u305f\u3081\u3001\u5225\u624b\u6bb5\u3067\u306e\u69cb\u7bc9\u3092\u691c\u8a0e\u3057\u307e\u3057\u305f\u3002
\n\u4eca\u56de\u306fNestJS\u3068kafkajs\u306e\u53cc\u65b9\u306e\u826f\u3055\u3092\u6d3b\u304b\u3057\u305f\u30ab\u30b9\u30bf\u30de\u30a4\u30ba\u6027\u306e\u9ad8\u3044Consumer\u3092\u4f5c\u6210\u3057\u3066\u307f\u307e\u3059\u3002<\/p>\n

NestJS\u306e\u30d7\u30ed\u30b8\u30a7\u30af\u30c8\u4f5c\u6210<\/h1>\n
$ <\/span>nest new tutorial-consumer\r\n\u26a1  We will scaffold your app in <\/span>a few seconds..\r\n\r\n? Which package manager would you \u2764\ufe0f  to use? npm\r\n<\/code><\/pre>\n
\u30d1\u30c3\u30b1\u30fc\u30b8\u30de\u30cd\u30fc\u30b8\u30e3\u30fc\u306b\u306fnpm\u3092\u5229\u7528\u3057\u307e\u3059<\/p>\n
Consumer\u7528\u306e\u30e2\u30b8\u30e5\u30fc\u30eb\u3092\u4f5c\u6210\u3059\u308b<\/h1>\n
$ <\/span>nest g module hello\r\nCREATE src\/hello\/hello.module.ts (<\/span>82 bytes)<\/span>\r\nUPDATE src\/app.module.ts (<\/span>312 bytes)<\/span>\r\n<\/code><\/pre>\n
KafkaConsumer\u7528\u306e\u57fa\u5e95\u30af\u30e9\u30b9\u3092\u4f5c\u6210\u3059\u308b<\/h1>\n
\u5404\u7a2e\u5177\u8c61\u306eKafkaConsumer\u304c\u72ec\u81ea\u306e\u30d3\u30b8\u30cd\u30b9\u30ed\u30b8\u30c3\u30af\u306b\u6ce8\u529b\u3067\u304d\u308b\u3088\u3046\u306b\u3001KafkaConsumer\u7528\u306e\u57fa\u5e95\u30af\u30e9\u30b9\u3092\u4f5c\u6210\u3057\u307e\u3059\u3002<\/p>\n
import<\/span> {<\/span>\r\n  Injectable<\/span>,<\/span>\r\n  OnModuleInit<\/span>,<\/span>\r\n  OnModuleDestroy<\/span>,<\/span>\r\n  Logger<\/span>,<\/span>\r\n}<\/span> from<\/span> '<\/span>@nestjs\/common<\/span>'<\/span>;<\/span>\r\nimport<\/span> {<\/span> Kafka<\/span>,<\/span> Consumer<\/span>,<\/span> KafkaMessage<\/span> }<\/span> from<\/span> '<\/span>kafkajs<\/span>'<\/span>;<\/span>\r\n\r\n\/**\r\n * KafkaConsumer\u306e\u57fa\u5e95\u30af\u30e9\u30b9\r\n *\/<\/span>\r\nexport<\/span> abstract<\/span> class<\/span> KafkaConsumer<\/span> implements<\/span> OnModuleInit<\/span>,<\/span> OnModuleDestroy<\/span> {<\/span>\r\n  \/**\r\n   * \u30af\u30e9\u30b9\u30e1\u30f3\u30d0\r\n   *\/<\/span>\r\n  private<\/span> readonly<\/span> kafka<\/span>:<\/span> Kafka<\/span>;<\/span>\r\n  private<\/span> readonly<\/span> logger<\/span>:<\/span> Logger<\/span> =<\/span> new<\/span> Logger<\/span>();<\/span>\r\n  private<\/span> consumer<\/span>:<\/span> Consumer<\/span>;<\/span> \/\/ onModuleInit\u304c\u547c\u3073\u51fa\u3055\u308c\u305f\u969b\u306b\u5024\u3092\u683c\u7d0d<\/span>\r\n\r\n  \/**\r\n   * \u62bd\u8c61\u30e1\u30f3\u30d0\r\n   *\/<\/span>\r\n  abstract<\/span> readonly<\/span> consumerGroupName<\/span>:<\/span> string<\/span>;<\/span>\r\n  abstract<\/span> readonly<\/span> consumerTopicName<\/span>:<\/span> string<\/span>;<\/span>\r\n\r\n  \/**\r\n   * \u30b3\u30f3\u30b9\u30c8\u30e9\u30af\u30bf\r\n   *\/<\/span>\r\n  constructor<\/span>()<\/span> {<\/span>\r\n    this<\/span>.<\/span>kafka<\/span> =<\/span> new<\/span> Kafka<\/span>({<\/span>\r\n      brokers<\/span>:<\/span> process<\/span>.<\/span>env<\/span>[<\/span>'<\/span>BROKER_ENDPOINTS<\/span>'<\/span>]?.<\/span>split<\/span>(<\/span>'<\/span>,<\/span>'<\/span>)<\/span> ??<\/span> [<\/span>\r\n        '<\/span>localhost:9093<\/span>'<\/span>,<\/span>\r\n      ],<\/span>\r\n    });<\/span>\r\n  }<\/span>\r\n\r\n  \/**\r\n   * \u30cf\u30f3\u30c9\u30e9\u51e6\u7406\r\n   *\/<\/span>\r\n  abstract<\/span> handler<\/span>(<\/span>message<\/span>:<\/span> KafkaMessage<\/span>):<\/span> void<\/span>;<\/span>\r\n\r\n  \/**\r\n   * \u30cf\u30f3\u30c9\u30e9\u30fc\u306e\u524d\u51e6\u7406\r\n   *\/<\/span>\r\n  private<\/span> actionBeforeHandler<\/span>():<\/span> void<\/span> {<\/span>\r\n    this<\/span>.<\/span>logger<\/span>.<\/span>log<\/span>(<\/span>`<\/span>${<\/span>this<\/span>.<\/span>consumerGroupName<\/span>}<\/span>\u306e\u51e6\u7406\u3092\u958b\u59cb\u3057\u307e\u3059`<\/span>);<\/span>\r\n    this<\/span>.<\/span>logger<\/span>.<\/span>log<\/span>(<\/span>`<\/span>${<\/span>this<\/span>.<\/span>consumerTopicName<\/span>}<\/span>\u304b\u3089\u30e1\u30c3\u30bb\u30fc\u30b8\u3092\u53d6\u5f97\u3057\u307e\u3059`<\/span>);<\/span>\r\n  }<\/span>\r\n\r\n  \/**\r\n   * \u30cf\u30f3\u30c9\u30e9\u30fc\u306e\u5f8c\u51e6\u7406\r\n   *\/<\/span>\r\n  private<\/span> actionAfterHandler<\/span>():<\/span> void<\/span> {<\/span>\r\n    this<\/span>.<\/span>logger<\/span>.<\/span>log<\/span>(<\/span>`<\/span>${<\/span>this<\/span>.<\/span>consumerGroupName<\/span>}<\/span>\u306e\u51e6\u7406\u3092\u7d42\u4e86\u3057\u307e\u3059`<\/span>);<\/span>\r\n  }<\/span>\r\n\r\n  \/**\r\n   * \u51aa\u7b49\u51e6\u7406\r\n   *\/<\/span>\r\n  private<\/span> isUniqueProcess<\/span>():<\/span> boolean<\/span> {<\/span>\r\n    \/\/ TODO: \u30a2\u30d7\u30ea\u30b1\u30fc\u30b7\u30e7\u30f3\u56fa\u6709\u306e\u51aa\u7b49\u30c1\u30a7\u30c3\u30af\u3092\u8a18\u8f09\u3059\u308b<\/span>\r\n    return<\/span> true<\/span>;<\/span>\r\n  }<\/span>\r\n\r\n  \/**\r\n   * \u5b9f\u884c\u51e6\u7406\r\n   *\/<\/span>\r\n  private<\/span> execute<\/span>(<\/span>partition<\/span>:<\/span> number<\/span>,<\/span> message<\/span>:<\/span> KafkaMessage<\/span>):<\/span> void<\/span> {<\/span>\r\n    this<\/span>.<\/span>actionBeforeHandler<\/span>();<\/span>\r\n    if <\/span>(<\/span>this<\/span>.<\/span>isUniqueProcess<\/span>())<\/span> {<\/span>\r\n      this<\/span>.<\/span>handler<\/span>(<\/span>message<\/span>);<\/span>\r\n    }<\/span> else<\/span> {<\/span>\r\n      this<\/span>.<\/span>logger<\/span>.<\/span>warn<\/span>(<\/span>`<\/span>${<\/span>this<\/span>.<\/span>consumerGroupName<\/span>}<\/span>\u306e\u51e6\u7406\u304c\u91cd\u8907\u3057\u307e\u3057\u305f`<\/span>);<\/span>\r\n    }<\/span>\r\n    this<\/span>.<\/span>actionAfterHandler<\/span>();<\/span>\r\n  }<\/span>\r\n}<\/span>\r\n<\/code><\/pre>\n
NestJS\u3067\u306f\u30e9\u30a4\u30d5\u30b5\u30a4\u30af\u30eb\u30a4\u30d9\u30f3\u30c8\u3068\u3044\u3046\u6a5f\u80fd\u304c\u5b58\u5728\u307e\u3059
\n@Module\u3001@Injectable\u3001@Controller\u30c7\u30b3\u30ec\u30fc\u30bf\u304c\u4ed8\u4e0e\u3055\u308c\u305f\u30af\u30e9\u30b9\u306b\u3042\u3089\u304b\u3058\u3081\u30e9\u30a4\u30d5\u30b5\u30a4\u30af\u30eb\u30e1\u30bd\u30c3\u30c9\u3092\u7528\u610f\u3057\u3066\u304a\u304f\u3068\u3001\u30e9\u30a4\u30d5\u30b5\u30a4\u30af\u30eb\u30a4\u30d9\u30f3\u30c8\u304c\u767a\u751f\u3057\u305f\u969b\u306b\u8a72\u5f53\u30b3\u30fc\u30c9\u3092\u547c\u3073\u51fa\u3057\u3066\u304f\u308c\u308b\u6a5f\u80fd\u3067\u3059\u3002
\n\u30e9\u30a4\u30d5\u30b5\u30a4\u30af\u30eb\u30a4\u30d9\u30f3\u30c8\u306b\u306f\u4e0b\u8a18\u304c\u5b58\u5728\u3057\u3001consumer\u8d77\u52d5\u6642\u306bonModuleInit()\u3092\u3001\u505c\u6b62\u6642\u306bonModuleDestroy()\u3092\u4eca\u56de\u306f\u5229\u7528\u3057\u307e\u3059<\/p>\n
\n
\u30e9\u30a4\u30d5\u30b5\u30a4\u30af\u30eb\u30e1\u30bd\u30c3\u30c9\u30d5\u30c3\u30af\u30e1\u30bd\u30c3\u30c9\u30b3\u30fc\u30eb\u306e\u30c8\u30ea\u30ac\u3068\u306a\u308b\u30e9\u30a4\u30d5\u30eb\u30b5\u30a4\u30af\u30eb\u30a4\u30d9\u30f3\u30c8onModuleInit()<\/code>\u30db\u30b9\u30c8\u30e2\u30b8\u30e5\u30fc\u30eb\u306e\u4f9d\u5b58\u95a2\u4fc2\u304c\u89e3\u6c7a\u3055\u308c\u305fonModuleDestroy()<\/code>\u7d42\u4e86\u30b7\u30b0\u30ca\u30eb\uff08SIGTERM\u7b49\uff09\u3092\u53d7\u3051\u53d6\u3063\u305f\u5f8c<\/div>\n<\/div>\n
  \/**\r\n   * \u30db\u30b9\u30c8\u30e2\u30b8\u30e5\u30fc\u30eb\u306e\u4f9d\u5b58\u95a2\u4fc2\u304c\u89e3\u6c7a\u3055\u308c\u305f\u76f4\u5f8c\u306e\u51e6\u7406\r\n   *\/<\/span>\r\n  async<\/span> onModuleInit<\/span>()<\/span> {<\/span>\r\n    this<\/span>.<\/span>logger<\/span>.<\/span>log<\/span>(<\/span>`<\/span>${<\/span>this<\/span>.<\/span>consumerGroupName<\/span>}<\/span>\u3092\u8d77\u52d5\u3057\u307e\u3059`<\/span>);<\/span>\r\n    this<\/span>.<\/span>consumer<\/span> =<\/span> this<\/span>.<\/span>kafka<\/span>.<\/span>consumer<\/span>({<\/span>\r\n      groupId<\/span>:<\/span> this<\/span>.<\/span>consumerGroupName<\/span>,<\/span>\r\n      heartbeatInterval<\/span>:<\/span> 20000<\/span>,<\/span>\r\n      sessionTimeout<\/span>:<\/span> 60000<\/span>,<\/span>\r\n    });<\/span>\r\n\r\n    await<\/span> this<\/span>.<\/span>consumer<\/span>.<\/span>connect<\/span>();<\/span>\r\n    await<\/span> this<\/span>.<\/span>consumer<\/span>.<\/span>subscribe<\/span>({<\/span>\r\n      topics<\/span>:<\/span> [<\/span>this<\/span>.<\/span>consumerTopicName<\/span>],<\/span>\r\n      fromBeginning<\/span>:<\/span> true<\/span>,<\/span>\r\n    });<\/span>\r\n    await<\/span> this<\/span>.<\/span>consumer<\/span>.<\/span>run<\/span>({<\/span>\r\n      eachMessage<\/span>:<\/span> async <\/span>({<\/span> partition<\/span>,<\/span> message<\/span> })<\/span> =><\/span> {<\/span>\r\n        this<\/span>.<\/span>execute<\/span>(<\/span>partition<\/span>,<\/span> message<\/span>);<\/span>\r\n      },<\/span>\r\n    });<\/span>\r\n    this<\/span>.<\/span>logger<\/span>.<\/span>log<\/span>(<\/span>`<\/span>${<\/span>this<\/span>.<\/span>consumerGroupName<\/span>}<\/span>\u304c\u8d77\u52d5\u3057\u307e\u3057\u305f`<\/span>);<\/span>\r\n  }<\/span>\r\n\r\n<\/code><\/pre>\n
\u7d42\u4e86\u30b7\u30b0\u30ca\u30eb\u3092\u53d7\u3051\u53d6\u3063\u305f\u969b\u306b\u3001consumer\u3092kafka\u304b\u3089\u5207\u65ad\u3059\u308b\u3088\u3046\u306bonModuleDestroy()\u30e1\u30bd\u30c3\u30c9\u306b\u5b9f\u88c5\u3092\u884c\u3044\u307e\u3059\u3002<\/p>\n
  \/**\r\n   * \u7d42\u4e86\u30b7\u30b0\u30ca\u30eb\u3092\u53d7\u3051\u53d6\u3063\u305f\u6642\u306e\u51e6\u7406\r\n   *\/<\/span>\r\n  async<\/span> onModuleDestroy<\/span>()<\/span> {<\/span>\r\n    this<\/span>.<\/span>logger<\/span>.<\/span>log<\/span>(<\/span>`<\/span>${<\/span>this<\/span>.<\/span>consumerGroupName<\/span>}<\/span>\u3092kafka\u304b\u3089\u5207\u65ad\u3057\u307e\u3059`<\/span>);<\/span>\r\n    await<\/span> this<\/span>.<\/span>consumer<\/span>.<\/span>disconnect<\/span>();<\/span>\r\n  }<\/span>\r\n<\/code><\/pre>\n
\u5177\u8c61\u306eConsumer\u306e\u4f5c\u6210<\/h2>\n
hello.consumer.ts\u3092\u624b\u52d5\u3067\u4f5c\u6210\u3057\u307e\u3059\u3002<\/p>\n
$ <\/span>touch <\/span>src\/hello\/hello.consumer.ts\r\n<\/code><\/pre>\n
\u5148\u307b\u3069\u4f5c\u6210\u3057\u305fKafkaConsumer\u30af\u30e9\u30b9\u3092\u7d99\u627f\u3055\u305b\u3066\u3001\u5177\u8c61\u306eConsumer\u30cf\u30f3\u30c9\u30e9\u3092\u4f5c\u6210\u3057\u307e\u3059
\n@Injectable()\u30c7\u30b3\u30ec\u30fc\u30bf\u3092\u3064\u3051\u3066\u304a\u304f\u3053\u3068\u3067Nest\u306e\u30d7\u30ed\u30d0\u30a4\u30c0\u3068\u3057\u3066\u8a8d\u8b58\u3055\u308c\u3001NestJS\u306e\u72ec\u81ea\u306eDI\u30b3\u30f3\u30c6\u30ca\u3067\u30a4\u30f3\u30b9\u30bf\u30f3\u30b9\u306e\u30e9\u30a4\u30d5\u30b5\u30a4\u30af\u30eb\u7ba1\u7406\u304c\u3055\u308c\u308b\u3088\u3046\u306b\u306a\u308a\u307e\u3059\u3002<\/p>\n
import<\/span> {<\/span> Injectable<\/span> }<\/span> from<\/span> '<\/span>@nestjs\/common<\/span>'<\/span>;<\/span>\r\nimport<\/span> {<\/span> KafkaMessage<\/span> }<\/span> from<\/span> '<\/span>kafkajs<\/span>'<\/span>;<\/span>\r\nimport<\/span> {<\/span> KafkaConsumer<\/span> }<\/span> from<\/span> '<\/span>src\/kafka.consumer<\/span>'<\/span>;<\/span>\r\n\r\n@<\/span>Injectable<\/span>()<\/span>\r\nexport<\/span> class<\/span> HelloConsumer<\/span> extends<\/span> KafkaConsumer<\/span> {<\/span>\r\n  readonly<\/span> consumerGroupName<\/span>:<\/span> string<\/span>;<\/span>\r\n  readonly<\/span> consumerTopicName<\/span>:<\/span> string<\/span>;<\/span>\r\n  constructor<\/span>()<\/span> {<\/span>\r\n    super<\/span>();<\/span>\r\n    this<\/span>.<\/span>consumerGroupName<\/span> =<\/span> '<\/span>HelloWorldConsumer<\/span>'<\/span>;<\/span>\r\n    this<\/span>.<\/span>consumerTopicName<\/span> =<\/span> '<\/span>TestTopic<\/span>'<\/span>;<\/span>\r\n  }<\/span>\r\n  handler<\/span>(<\/span>message<\/span>:<\/span> KafkaMessage<\/span>):<\/span> void<\/span> {<\/span>\r\n    \/**\r\n     * Consumer\u56fa\u6709\u306e\u30ed\u30b8\u30c3\u30af\u3092\u66f8\u304f\r\n     *\/<\/span>\r\n    \r\n    \r\n  }<\/span>\r\n}<\/span>\r\n\r\n<\/code><\/pre>\n
\u30e2\u30b8\u30e5\u30fc\u30eb\u306eproviders\u306b\u5148\u307b\u3069\u4f5c\u6210\u3057\u305fHelloConsumer\u306e\u767b\u9332\u3092\u884c\u3044\u307e\u3059\u3002<\/p>\n
import<\/span> {<\/span> Module<\/span> }<\/span> from<\/span> '<\/span>@nestjs\/common<\/span>'<\/span>;<\/span>\r\nimport<\/span> {<\/span> HelloConsumer<\/span> }<\/span> from<\/span> '<\/span>.\/hello.consumer<\/span>'<\/span>;<\/span>\r\nimport<\/span> {<\/span> HelloService<\/span> }<\/span> from<\/span> '<\/span>.\/hello.service<\/span>'<\/span>;<\/span>\r\n\r\n@<\/span>Module<\/span>({<\/span>\r\n  providers<\/span>:<\/span> [<\/span>HelloConsumer<\/span>],<\/span>\r\n})<\/span>\r\nexport<\/span> class<\/span> HelloModule<\/span> {}<\/span>\r\n\r\n<\/code><\/pre>\n
ApacheKafka\u3092\u8d77\u52d5\u3059\u308b<\/h1>\n
ApacheKafka\u3092\u8d77\u52d5\u3059\u308b\u305f\u3081\u306edocker-compose.yml\u3092\u30d7\u30ed\u30b8\u30a7\u30af\u30c8\u76f4\u4e0b\u306b\u914d\u7f6e\u3057\u8d77\u52d5\u3092\u884c\u3044\u307e\u3059<\/p>\n
$ <\/span>docker-compose up -d<\/span>\r\n<\/code><\/pre>\n
version<\/span>:<\/span> '<\/span>2'<\/span>\r\nservices<\/span>:<\/span>\r\n  # -------------------------- #<\/span>\r\n  # Zookeeper<\/span>\r\n  # -------------------------- #<\/span>\r\n  zookeeper<\/span>:<\/span>\r\n    image<\/span>:<\/span> '<\/span>bitnami\/zookeeper:latest'<\/span>\r\n    ports<\/span>:<\/span>\r\n      -<\/span> '<\/span>2181:2181'<\/span>\r\n    environment<\/span>:<\/span>\r\n      -<\/span> ALLOW_ANONYMOUS_LOGIN=yes<\/span>\r\n    container_name<\/span>:<\/span> zookeeper<\/span>\r\n    tty<\/span>:<\/span> true<\/span>\r\n    networks<\/span>:<\/span> \r\n      -<\/span> kafka_network<\/span>\r\n  # -------------------------- #<\/span>\r\n  # Kafka(Broker)<\/span>\r\n  # -------------------------- #<\/span>\r\n  kafka<\/span>:<\/span>\r\n    image<\/span>:<\/span> '<\/span>bitnami\/kafka:latest'<\/span>\r\n    ports<\/span>:<\/span>\r\n      -<\/span> '<\/span>9093:9093'<\/span>\r\n      -<\/span> '<\/span>9094:9094'<\/span>\r\n    container_name<\/span>:<\/span> kafka<\/span>\r\n    environment<\/span>:<\/span>\r\n      -<\/span> KAFKA_CFG_ZOOKEEPER_CONNECT=zookeeper:2181<\/span>\r\n      -<\/span> ALLOW_PLAINTEXT_LISTENER=yes<\/span>\r\n      -<\/span> KAFKA_BROKER_ID=1<\/span>\r\n      -<\/span> KAFKA_CFG_LISTENER_SECURITY_PROTOCOL_MAP=CLIENT:PLAINTEXT,EXTERNAL:PLAINTEXT,EXTERNAL_DOCKER:PLAINTEXT<\/span>\r\n      -<\/span> KAFKA_CFG_LISTENERS=CLIENT:\/\/:9092,EXTERNAL:\/\/:9093,EXTERNAL_DOCKER:\/\/:9094<\/span>\r\n      -<\/span> KAFKA_CFG_ADVERTISED_LISTENERS=CLIENT:\/\/kafka:9092,EXTERNAL:\/\/localhost:9093,EXTERNAL_DOCKER:\/\/host.docker.internal:9094<\/span>\r\n      -<\/span> KAFKA_INTER_BROKER_LISTENER_NAME=CLIENT<\/span>\r\n    depends_on<\/span>:<\/span>\r\n      -<\/span> zookeeper<\/span>\r\n    tty<\/span>:<\/span> true<\/span>\r\n    networks<\/span>:<\/span> \r\n      -<\/span> kafka_network<\/span>\r\n  # -------------------------- #<\/span>\r\n  # Kafka UI<\/span>\r\n  # -------------------------- #<\/span>\r\n  kafka-ui<\/span>:<\/span>\r\n    image<\/span>:<\/span> provectuslabs\/kafka-ui<\/span>\r\n    container_name<\/span>:<\/span> kafka-ui<\/span>\r\n    ports<\/span>:<\/span>\r\n      -<\/span> \"<\/span>8080:8080\"<\/span>\r\n    restart<\/span>:<\/span> always<\/span>\r\n    environment<\/span>:<\/span>\r\n      -<\/span> KAFKA_CLUSTERS_0_NAME=local<\/span>\r\n      -<\/span> KAFKA_CLUSTERS_0_BOOTSTRAPSERVERS=kafka:9092<\/span>\r\n      -<\/span> KAFKA_CLUSTERS_0_ZOOKEEPER=zookeeper:2181<\/span>\r\n      -<\/span> KAFKA_CLUSTERS_0_READONLY=false<\/span>\r\n    networks<\/span>:<\/span> \r\n      -<\/span> kafka_network<\/span>\r\nnetworks<\/span>:<\/span>\r\n  kafka_network<\/span>:<\/span>\r\n<\/code><\/pre>\n
kafka-ui\u3092\u30d6\u30e9\u30a6\u30b6\u3067\u958b\u304d\u3001\u30c8\u30d4\u30c3\u30af\u3092\u4f5c\u6210\u3059\u308b<\/h1>\n
\"\u30b9\u30af\u30ea\u30fc\u30f3\u30b7\u30e7\u30c3\u30c8<\/div>\n
\"\u30b9\u30af\u30ea\u30fc\u30f3\u30b7\u30e7\u30c3\u30c8<\/div>\n
NestJS\u306eKafkaConsumer\u3092\u8d77\u52d5<\/h1>\n
\u4e0b\u8a18\u30b3\u30de\u30f3\u30c9\u3067NestJS\u306eConsumer\u30a2\u30d7\u30ea\u30b1\u30fc\u30b7\u30e7\u30f3\u3092\u8d77\u52d5\u3057\u307e\u3059<\/p>\n
$ <\/span>npm run start:dev\r\n[<\/span>Nest] 25626  - 2023\/01\/03 14:48:44     LOG [<\/span>NestFactory] Starting Nest application...\r\n[<\/span>Nest] 25626  - 2023\/01\/03 14:48:44     LOG [<\/span>InstanceLoader] HelloModule dependencies initialized +29ms\r\n[<\/span>Nest] 25626  - 2023\/01\/03 14:48:44     LOG [<\/span>InstanceLoader] AppModule dependencies initialized +1ms\r\n[<\/span>Nest] 25626  - 2023\/01\/03 14:48:44     LOG [<\/span>RoutesResolver] AppController {<\/span>\/}<\/span>: +4ms\r\n[<\/span>Nest] 25626  - 2023\/01\/03 14:48:44     LOG [<\/span>RouterExplorer] Mapped {<\/span>\/, GET}<\/span> route +2ms\r\n[<\/span>Nest] 25626  - 2023\/01\/03 14:48:44     LOG HelloWorldConsumer\u3092\u8d77\u52d5\u3057\u307e\u3059\r\n{<\/span>\"level\"<\/span>:\"INFO\"<\/span>,\"timestamp\"<\/span>:\"2023-01-03T05:48:44.366Z\"<\/span>,\"logger\"<\/span>:\"kafkajs\"<\/span>,\"message\"<\/span>:\"[Consumer] Starting\"<\/span>,\"groupId\"<\/span>:\"HelloWorldConsumer\"<\/span>}<\/span>\r\n{<\/span>\"level\"<\/span>:\"INFO\"<\/span>,\"timestamp\"<\/span>:\"2023-01-03T05:48:44.403Z\"<\/span>,\"logger\"<\/span>:\"kafkajs\"<\/span>,\"message\"<\/span>:\"[ConsumerGroup] Consumer has joined the group\"<\/span>,\"groupId\"<\/span>:\"HelloWorldConsumer\"<\/span>,\"memberId\"<\/span>:\"kafkajs-1a203b6f-f9c3-4917-809f-849b6f4d7408\"<\/span>,\"leaderId\"<\/span>:\"kafkajs-1a203b6f-f9c3-4917-809f-849b6f4d7408\"<\/span>,\"isLeader\"<\/span>:true,\"memberAssignment\"<\/span>:{<\/span>\"TestTopic\"<\/span>:[0]}<\/span>,\"groupProtocol\"<\/span>:\"RoundRobinAssigner\"<\/span>,\"duration\"<\/span>:36}<\/span>\r\n[<\/span>Nest] 25626  - 2023\/01\/03 14:48:44     LOG HelloWorldConsumer\u304c\u8d77\u52d5\u3057\u307e\u3057\u305f\r\n[<\/span>Nest] 25626  - 2023\/01\/03 14:48:44     LOG [<\/span>NestApplication] Nest application successfully started +6ms\r\n<\/code><\/pre>\n
\"\u30b9\u30af\u30ea\u30fc\u30f3\u30b7\u30e7\u30c3\u30c8<\/div>\n
KafkaUI\u304b\u3089\u30e1\u30c3\u30bb\u30fc\u30b8\u3092\u9001\u4fe1\u3059\u308b<\/h2>\n
\"\u30b9\u30af\u30ea\u30fc\u30f3\u30b7\u30e7\u30c3\u30c8<\/div>\n
\u4e0b\u8a18\u306e\u3088\u3046\u306bLOG \u53d7\u4fe1\u3057\u305f\u30e1\u30c3\u30bb\u30fc\u30b8\uff1aTest\u3068\u30ed\u30b0\u304c\u8868\u793a\u3055\u308c\u3066\u308b\u3053\u3068\u304c\u78ba\u8a8d\u3067\u304d\u307e\u3057\u305f\u3002<\/p>\n
[<\/span>Nest] 26241  - 2023\/01\/03 14:53:00     LOG [<\/span>NestFactory] Starting Nest application...\r\n[<\/span>Nest] 26241  - 2023\/01\/03 14:53:00     LOG [<\/span>InstanceLoader] HelloModule dependencies initialized +30ms\r\n[<\/span>Nest] 26241  - 2023\/01\/03 14:53:00     LOG [<\/span>InstanceLoader] AppModule dependencies initialized +1ms\r\n[<\/span>Nest] 26241  - 2023\/01\/03 14:53:00     LOG [<\/span>RoutesResolver] AppController {<\/span>\/}<\/span>: +4ms\r\n[<\/span>Nest] 26241  - 2023\/01\/03 14:53:00     LOG [<\/span>RouterExplorer] Mapped {<\/span>\/, GET}<\/span> route +2ms\r\n[<\/span>Nest] 26241  - 2023\/01\/03 14:53:00     LOG HelloWorldConsumer\u3092\u8d77\u52d5\u3057\u307e\u3059\r\n{<\/span>\"level\"<\/span>:\"INFO\"<\/span>,\"timestamp\"<\/span>:\"2023-01-03T05:53:00.930Z\"<\/span>,\"logger\"<\/span>:\"kafkajs\"<\/span>,\"message\"<\/span>:\"[Consumer] Starting\"<\/span>,\"groupId\"<\/span>:\"HelloWorldConsumer\"<\/span>}<\/span>\r\n{<\/span>\"level\"<\/span>:\"INFO\"<\/span>,\"timestamp\"<\/span>:\"2023-01-03T05:53:51.359Z\"<\/span>,\"logger\"<\/span>:\"kafkajs\"<\/span>,\"message\"<\/span>:\"[ConsumerGroup] Consumer has joined the group\"<\/span>,\"groupId\"<\/span>:\"HelloWorldConsumer\"<\/span>,\"memberId\"<\/span>:\"kafkajs-3d4ce9f2-23ce-4d09-96c2-7f0f2b76e3a2\"<\/span>,\"leaderId\"<\/span>:\"kafkajs-3d4ce9f2-23ce-4d09-96c2-7f0f2b76e3a2\"<\/span>,\"isLeader\"<\/span>:true,\"memberAssignment\"<\/span>:{<\/span>\"TestTopic\"<\/span>:[0]}<\/span>,\"groupProtocol\"<\/span>:\"RoundRobinAssigner\"<\/span>,\"duration\"<\/span>:50428}<\/span>\r\n[<\/span>Nest] 26241  - 2023\/01\/03 14:53:51     LOG HelloWorldConsumer\u304c\u8d77\u52d5\u3057\u307e\u3057\u305f\r\n[<\/span>Nest] 26241  - 2023\/01\/03 14:53:51     LOG [<\/span>NestApplication] Nest application successfully started +10ms\r\n[<\/span>Nest] 26241  - 2023\/01\/03 14:56:22     LOG HelloWorldConsumer\u306e\u51e6\u7406\u3092\u958b\u59cb\u3057\u307e\u3059\r\n[<\/span>Nest] 26241  - 2023\/01\/03 14:56:22     LOG TestTopic\u304b\u3089\u30e1\u30c3\u30bb\u30fc\u30b8\u3092\u53d6\u5f97\u3057\u307e\u3059\r\n[<\/span>Nest] 26241  - 2023\/01\/03 14:56:22     LOG \u53d7\u4fe1\u3057\u305f\u30e1\u30c3\u30bb\u30fc\u30b8\uff1aTest\r\n[<\/span>Nest] 26241  - 2023\/01\/03 14:56:22     LOG HelloWorldConsumer\u306e\u51e6\u7406\u3092\u7d42\u4e86\u3057\u307e\u3059\r\n<\/code><\/pre>\n
\u304a\u308f\u308a\u306b<\/h1>\n
\u672c\u6295\u7a3f\u3067\u306fNestJS\u3068kafkajs\u3092\u7d44\u307f\u5408\u308f\u305b\u3066KafkaConsumer\u3092\u4f5c\u3063\u3066\u307f\u307e\u3057\u305f\u3002
\n\u30a2\u30c0\u30d7\u30bf\u30fc\u90e8\u5206\u306e\u5b9f\u88c5\u306b\u304a\u3044\u3066NestJS\u306e\u30b3\u30f3\u30c8\u30ed\u30fc\u30e9\u30fc\u6a5f\u80fd\u3092\u5229\u7528\u305b\u305a\u306b\u4f5c\u3063\u3066\u307f\u307e\u3057\u305f\u304c\u3001
\n\u5404\u7a2eConsumer\u306e\u30e9\u30a4\u30d5\u30b5\u30a4\u30af\u30eb\u7ba1\u7406\u306fNestJS\u306e\u6a5f\u80fd\u306b\u4efb\u305b\u3066\u3001Consumer\u5b9f\u88c5\u8005\u304c\u30d3\u30b8\u30cd\u30b9\u30ed\u30b8\u30c3\u30af\u3092\u30b7\u30f3\u30d7\u30eb\u306b\u5b9f\u88c5\u3067\u304d\u308b\u3088\u3046\u306b\u306a\u3063\u3066\u307e\u3059\u3002<\/p>\n","protected":false},"excerpt":{"rendered":"
\u306f\u3058\u3081\u306b NestJS\u306e\u30d5\u30ec\u30fc\u30e0\u30ef\u30fc\u30af\u306e\u6069\u6075\u3082\u53d7\u3051\u3064\u3064\u3082\u30a4\u30d9\u30f3\u30c8\u99c6\u52d5\u306a\u975e\u540c\u671f\u30a2\u30d7\u30ea\u30b1\u30fc\u30b7\u30e7\u30f3\u3092\u4f5c\u308a\u305f\u3044\uff01\u3068\u3044\u3046 […]<\/p>\n","protected":false},"author":3,"featured_media":0,"comment_status":"closed","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[],"class_list":["post-46725","post","type-post","status-publish","format-standard","hentry","category-uncategorized"],"yoast_head":"\n- Blog - Silicon Cloud<\/title>\n<meta name=\"robots\" content=\"index, follow, max-snippet:-1, max-image-preview:large, max-video-preview:-1\" \/>\n<link rel=\"canonical\" href=\"https:\/\/www.silicloud.com\/zh\/blog\/46725-2\/\" \/>\n<meta property=\"og:locale\" content=\"zh_CN\" \/>\n<meta property=\"og:type\" content=\"article\" \/>\n<meta property=\"og:description\" content=\"\u306f\u3058\u3081\u306b NestJS\u306e\u30d5\u30ec\u30fc\u30e0\u30ef\u30fc\u30af\u306e\u6069\u6075\u3082\u53d7\u3051\u3064\u3064\u3082\u30a4\u30d9\u30f3\u30c8\u99c6\u52d5\u306a\u975e\u540c\u671f\u30a2\u30d7\u30ea\u30b1\u30fc\u30b7\u30e7\u30f3\u3092\u4f5c\u308a\u305f\u3044\uff01\u3068\u3044\u3046 […]\" \/>\n<meta property=\"og:url\" content=\"https:\/\/www.silicloud.com\/zh\/blog\/46725-2\/\" \/>\n<meta property=\"og:site_name\" content=\"Blog - Silicon Cloud\" \/>\n<meta property=\"article:published_time\" content=\"2023-03-10T15:32:50+00:00\" \/>\n<meta property=\"article:modified_time\" content=\"2024-05-04T04:52:09+00:00\" \/>\n<meta property=\"og:image\" content=\"https:\/\/cdn.silicloud.com\/blog-img\/blog\/img\/657d660437434c4406d08da7\/3-0.png\" \/>\n<meta name=\"author\" content=\"\u97f5, \u79d1\" \/>\n<meta name=\"twitter:card\" content=\"summary_large_image\" \/>\n<meta name=\"twitter:label1\" content=\"\u4f5c\u8005\" \/>\n\t<meta name=\"twitter:data1\" content=\"\u97f5, \u79d1\" \/>\n\t<meta name=\"twitter:label2\" content=\"\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4\" \/>\n\t<meta name=\"twitter:data2\" content=\"4 \u5206\" \/>\n<script type=\"application\/ld+json\" class=\"yoast-schema-graph\">{\"@context\":\"https:\/\/schema.org\",\"@graph\":[{\"@type\":\"WebPage\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/46725-2\/\",\"url\":\"https:\/\/www.silicloud.com\/zh\/blog\/46725-2\/\",\"name\":\"- Blog - Silicon Cloud\",\"isPartOf\":{\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#website\"},\"datePublished\":\"2023-03-10T15:32:50+00:00\",\"dateModified\":\"2024-05-04T04:52:09+00:00\",\"author\":{\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/6530331a63adef3b3443a1fab53a0e6e\"},\"inLanguage\":\"zh-Hans\",\"potentialAction\":[{\"@type\":\"ReadAction\",\"target\":[\"https:\/\/www.silicloud.com\/zh\/blog\/46725-2\/\"]}]},{\"@type\":\"WebSite\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#website\",\"url\":\"https:\/\/www.silicloud.com\/zh\/blog\/\",\"name\":\"Blog - Silicon Cloud\",\"description\":\"\",\"inLanguage\":\"zh-Hans\"},{\"@type\":\"Person\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/6530331a63adef3b3443a1fab53a0e6e\",\"name\":\"\u97f5, \u79d1\",\"image\":{\"@type\":\"ImageObject\",\"inLanguage\":\"zh-Hans\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/image\/\",\"url\":\"https:\/\/secure.gravatar.com\/avatar\/429ccb39b3fff5188bc17986222cfb0936cbadb8cc933cff04ab5ca01bd30a08?s=96&d=mm&r=g\",\"contentUrl\":\"https:\/\/secure.gravatar.com\/avatar\/429ccb39b3fff5188bc17986222cfb0936cbadb8cc933cff04ab5ca01bd30a08?s=96&d=mm&r=g\",\"caption\":\"\u97f5, \u79d1\"},\"url\":\"https:\/\/www.silicloud.com\/zh\/blog\/author\/yunke\/\"},{\"@type\":\"ImageObject\",\"inLanguage\":\"zh-Hans\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/46725-2\/#local-main-organization-logo\",\"url\":\"\",\"contentUrl\":\"\",\"caption\":\"Blog - Silicon Cloud\"}]}<\/script>\n<!-- \/ Yoast SEO Premium plugin. -->","yoast_head_json":{"title":"- Blog - Silicon Cloud","robots":{"index":"index","follow":"follow","max-snippet":"max-snippet:-1","max-image-preview":"max-image-preview:large","max-video-preview":"max-video-preview:-1"},"canonical":"https:\/\/www.silicloud.com\/zh\/blog\/46725-2\/","og_locale":"zh_CN","og_type":"article","og_description":"\u306f\u3058\u3081\u306b NestJS\u306e\u30d5\u30ec\u30fc\u30e0\u30ef\u30fc\u30af\u306e\u6069\u6075\u3082\u53d7\u3051\u3064\u3064\u3082\u30a4\u30d9\u30f3\u30c8\u99c6\u52d5\u306a\u975e\u540c\u671f\u30a2\u30d7\u30ea\u30b1\u30fc\u30b7\u30e7\u30f3\u3092\u4f5c\u308a\u305f\u3044\uff01\u3068\u3044\u3046 […]","og_url":"https:\/\/www.silicloud.com\/zh\/blog\/46725-2\/","og_site_name":"Blog - Silicon Cloud","article_published_time":"2023-03-10T15:32:50+00:00","article_modified_time":"2024-05-04T04:52:09+00:00","og_image":[{"url":"https:\/\/cdn.silicloud.com\/blog-img\/blog\/img\/657d660437434c4406d08da7\/3-0.png"}],"author":"\u97f5, \u79d1","twitter_card":"summary_large_image","twitter_misc":{"\u4f5c\u8005":"\u97f5, \u79d1","\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4":"4 \u5206"},"schema":{"@context":"https:\/\/schema.org","@graph":[{"@type":"WebPage","@id":"https:\/\/www.silicloud.com\/zh\/blog\/46725-2\/","url":"https:\/\/www.silicloud.com\/zh\/blog\/46725-2\/","name":"- Blog - Silicon Cloud","isPartOf":{"@id":"https:\/\/www.silicloud.com\/zh\/blog\/#website"},"datePublished":"2023-03-10T15:32:50+00:00","dateModified":"2024-05-04T04:52:09+00:00","author":{"@id":"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/6530331a63adef3b3443a1fab53a0e6e"},"inLanguage":"zh-Hans","potentialAction":[{"@type":"ReadAction","target":["https:\/\/www.silicloud.com\/zh\/blog\/46725-2\/"]}]},{"@type":"WebSite","@id":"https:\/\/www.silicloud.com\/zh\/blog\/#website","url":"https:\/\/www.silicloud.com\/zh\/blog\/","name":"Blog - Silicon Cloud","description":"","inLanguage":"zh-Hans"},{"@type":"Person","@id":"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/6530331a63adef3b3443a1fab53a0e6e","name":"\u97f5, \u79d1","image":{"@type":"ImageObject","inLanguage":"zh-Hans","@id":"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/image\/","url":"https:\/\/secure.gravatar.com\/avatar\/429ccb39b3fff5188bc17986222cfb0936cbadb8cc933cff04ab5ca01bd30a08?s=96&d=mm&r=g","contentUrl":"https:\/\/secure.gravatar.com\/avatar\/429ccb39b3fff5188bc17986222cfb0936cbadb8cc933cff04ab5ca01bd30a08?s=96&d=mm&r=g","caption":"\u97f5, \u79d1"},"url":"https:\/\/www.silicloud.com\/zh\/blog\/author\/yunke\/"},{"@type":"ImageObject","inLanguage":"zh-Hans","@id":"https:\/\/www.silicloud.com\/zh\/blog\/46725-2\/#local-main-organization-logo","url":"","contentUrl":"","caption":"Blog - Silicon Cloud"}]}},"_links":{"self":[{"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts\/46725","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/users\/3"}],"replies":[{"embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/comments?post=46725"}],"version-history":[{"count":2,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts\/46725\/revisions"}],"predecessor-version":[{"id":98429,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts\/46725\/revisions\/98429"}],"wp:attachment":[{"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/media?parent=46725"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/categories?post=46725"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/tags?post=46725"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}