GitHub user ppluck deleted a comment on the discussion: Rocketmq Rust clients:
I have an error for "..." while consuming a message.
supplement：
I find that client_type cannot be modified in ClientOption.
```rust
impl Default for ClientOption {
fn default() -> Self {
ClientOption {
client_type: ClientType::Producer,
group: None,
namespace: "".to_string(),
access_url: "localhost:8081".to_string(),
enable_tls: false,
timeout: Duration::from_secs(3),
long_polling_timeout: Duration::from_secs(40),
access_key: None,
secret_key: None,
}
}
}
```
GitHub link:
https://github.com/apache/rocketmq-clients/discussions/737#discussioncomment-9233489
----
This is an automatically sent email for dev@rocketmq.apache.org.
To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
