search

rabbitmq / rabbitmq-stream-rust-client

A client library for RabbitMQ streams
Other
152 stars 14 forks source link

run example environment.rs with error #183

Closed xbitlabs closed 1 year ago

xbitlabs commented 1 year ago

Describe the bug

run example environment.rs with error

E:/thesis/chat/chat-server/target/debug/rabbitmq.exe 2023-07-27T10:26:31.916657Z TRACE rabbitmq_stream_client::client::dispatcher: Dispatcher task: listening for messages 2023-07-27T10:26:31.916952Z TRACE tokio_util::codec::framed_impl: flushing framed transport 2023-07-27T10:26:31.917068Z TRACE tokio_util::codec::framed_impl: writing; remaining=16 2023-07-27T10:26:31.917250Z TRACE tokio_util::codec::framed_impl: framed transport flushed 2023-07-27T10:26:31.917949Z TRACE tokio_util::codec::framed_impl: attempting to decode a frame 2023-07-27T10:26:31.918074Z TRACE tokio_util::codec::framed_impl: Got an error, going to errored state 2023-07-27T10:26:31.918205Z TRACE rabbitmq_stream_client::client::dispatcher: Error from stream Protocol(Decode(UnsupportedResponseType(0))) 2023-07-27T10:26:31.918279Z TRACE rabbitmq_stream_client::client::dispatcher: Stream closed 2023-07-27T10:26:31.918410Z TRACE rabbitmq_stream_client::client: Closing client

Reproduction steps

erlang version otp_win64_25.3.2.4 rabbitmq version rabbitmq-server-3.12.2

run example environment.rs

Expected behavior

2023-07-27T10:26:31.917949Z TRACE tokio_util::codec::framed_impl: attempting to decode a frame 2023-07-27T10:26:31.918074Z TRACE tokio_util::codec::framed_impl: Got an error, going to errored state 2023-07-27T10:26:31.918205Z TRACE rabbitmq_stream_client::client::dispatcher: Error from stream Protocol(Decode(UnsupportedResponseType(0))) 2023-07-27T10:26:31.918279Z TRACE rabbitmq_stream_client::client::dispatcher: Stream closed 2023-07-27T10:26:31.918410Z TRACE rabbitmq_stream_client::client: Closing client

Additional context

No response

Gsantomaggio commented 1 year ago

It seems that there is some message not stored correctly.

  1. Can you please share the server logs?
  2. Can you try with docker, like:

Stop the your server then:

 docker run -it --rm --name rabbitmq -p 5552:5552 -p 15672:15672 \
    -e RABBITMQ_SERVER_ADDITIONAL_ERL_ARGS='-rabbitmq_stream advertised_host localhost' \
    rabbitmq:3.13.0-beta.2-management

then

docker exec rabbitmq    rabbitmq-plugins enable rabbitmq_stream_management
Gsantomaggio commented 1 year ago

Are you using the last version? 0.2.0 ?

xbitlabs commented 1 year ago

Are you using the last version? 0.2.0 ?

Sorry, it's my problem, it's fine after enable stream plugin and add a new user