fix:[TD-258900]modify tmq trans conflict to db level

f19c1ea3 · wmmhello · 8fc8aad1 · f19c1ea3
隐藏空白更改
内联并排

Showing with 1 addition and 1 deletion

source/dnode/mnode/impl/src/mndConsumer.c source/dnode/mnode/impl/src/mndConsumer.c +1 -1

未找到文件。
--- a/source/dnode/mnode/impl/src/mndConsumer.c
+++ b/source/dnode/mnode/impl/src/mndConsumer.c
@@ -577,7 +577,7 @@ int32_t mndSetConsumerCommitLogs(SMnode *pMnode, STrans *pTrans, SMqConsumerObj
  return 0;
 }

-static int32_t validateTopics(STrans *pTrans, const SArray *pTopicList, SMnode *pMnode, const char *pUser) {
+static int32_t validateTopics(const SArray *pTopicList, SMnode *pMnode, const char *pUser) {
  int32_t numOfTopics = taosArrayGetSize(pTopicList);

  for (int32_t i = 0; i < numOfTopics; i++) {