0

突然、apache kafka コンシューマ グループの実行プロセスで問題が発生しました。この問題が発生する理由について、どなたかご意見をお聞かせください。

  NestedError: topic/partition change check failed
      at _checkTopicPartitionChange (<system-path>/node_modules/kafka-node/lib/consumerGroup.js:295:37)
      at client.loadMetadataForTopics (<system-path>/node_modules/kafka-node/lib/consumerGroup.js:323:14)
      at async.series (<system-path>/node_modules/kafka-node/lib/kafkaClient.js:919:7)
      at <system-path>/node_modules/kafka-node/node_modules/async/dist/async.js:3888:9
      at <system-path>/node_modules/kafka-node/node_modules/async/dist/async.js:473:16
      at iterateeCallback (<system-path>/node_modules/kafka-node/node_modules/async/dist/async.js:988:17)
      at <system-path>/node_modules/kafka-node/node_modules/async/dist/async.js:969:16
      at <system-path>/node_modules/kafka-node/node_modules/async/dist/async.js:3885:13
      at Timeout.setTimeout [as _onTimeout] (<system-path>/node_modules/kafka-node/lib/kafkaClient.js:491:5)
      at ontimeout (timers.js:436:11)
      at tryOnTimeout (timers.js:300:5)
      at listOnTimeout (timers.js:263:5)
      at Timer.processTimers (timers.js:223:10)
  Caused By: TimeoutError: Request timed out after 30000ms
      at new TimeoutError (<system-path>/node_modules/kafka-node/lib/errors/TimeoutError.js:6:9)
      at Timeout.setTimeout [as _onTimeout] (<system-path>/node_modules/kafka-node/lib/kafkaClient.js:491:14)
      at ontimeout (timers.js:436:11)
      at tryOnTimeout (timers.js:300:5)
      at listOnTimeout (timers.js:263:5)
      at Timer.processTimers (timers.js:223:10)
  (node:12516) DeprecationWarning: collection.ensureIndex is deprecated. Use createIndexes instead.

どんな助けもかなりのものです。

4

0 に答える 0