无法使用 RabbitMQ 引擎为 clickhouse 表创建 ack

Question

我无法直接在 ClickHouse 的 SQL 语法中设置确认参数，但我需要在获取此表后删除消息。

create table MyTable(id Int64)engine = RabbitMQ SETTINGS  rabbitmq_host_port = 'localhost:5672', 
                            rabbitmq_exchange_name ='exchange', 
                            rabbitmq_exchange_type = 'direct', 
                            rabbitmq_routing_key_list = 'serv', 
                            rabbitmq_username = 'user', 
                            rabbitmq_password = 'password', 
                            rabbitmq_format = 'JSONEachRow"

我尝试在clickhouse文档中查找ack设置但没有找到。

Answer 1

Rabbitmq 引擎使用手动确认，并且不允许将其更改为自动，如果这就是您的意思，例如只有在成功发送 ack 后，消息才会从队列中删除，此行为不可更改。有一些选项可以配置rabbitmq队列设置 - 这可以通过名为rabbitmq_queue_settings_list的引擎设置来完成。但消费者的行为是不可改变的。可能您指的是消费者端的确认选项 - 我们确实使用标志“multiple”来一次确认多个消息。