RabbitMq消费者不工作，因为micronaut将执行器线程分配给Kafka消费者

bxfogqkk 于 2023-03-02 发布在 RabbitMQ

关注(0)|答案(1)|浏览(184)

我在Kotlin的micronaut v3.4.3中运行Kafka，最近我使用micronaut-rabbitmq v3.4.0将RabbitMq与服务器集成。在文档中提到要在application. yml中指定RabbitMq消费者的执行器。
现在，当服务器启动时，由于Kafka侦听器已经无限期地使用执行器线程，RabbitMq使用者无法获得这些线程上的锁。
那么，有没有办法同时为Kafka和RabbitMq隔离消费者执行器线程呢？

rabbitmq

来源：https://stackoverflow.com/questions/75096765/rabbitmq-consumer-not-working-because-micronaut-assigns-executor-threads-to-kafk

1条答案

按热度按时间

nhaq1z211#

我得到了答案，问题是我需要为RabbitMq和Kafka指定不同的消费者执行器线程。
这就是我如何通过在我的yml文件中添加这个来做到这一点。

micronaut:
  executors:
    rabbit:
      type: FIXED
    consumer:
      type: FIXED

在微型宇航员的结构中

rabbitmq:
  uri: amqp://guest@localhost:5672
  consumer-executor: rabbit

赞(0）回复(0）举报 2023-03-02

我来回答

RabbitMq消费者不工作，因为micronaut将执行器线程分配给Kafka消费者

1条答案

相关问题

热门标签

最新问答