Skip to content

[Bug] Using grpc async subscribe with rocketmq doesn't ack the message #745

@xwm1992

Description

@xwm1992

Search before asking

  • I had searched in the issues and found no similar issues.

Environment

Window

EventMesh version

Other

What happened

image
image

How to reproduce

First, I run the code under the grpc branch, use the CloudEventPublishInstance send the message to topic TEST-TOPIC-GRPC-ASYNC, and use EventMeshAsyncSubscribe the topic, after the client receive the message, didn't ack the offset of the topic, when I restarted the consumer client, the client reconsume the message again.

Second, for cloudevents, miss the specversion attribute cause the exception in eventmesh grpc client.

Debug logs

No response

Are you willing to submit PR?

  • Yes I am willing to submit a PR!

Metadata

Metadata

Assignees

No one assigned

    Labels

    bugSomething isn't working

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions