Skip to content

pull mode consume history message very slow #1134

Open
@UnderTreeTech

Description

@UnderTreeTech

First I produce 1k msg to broker, then I run the examples/consumer/pull/pull.go code with minor changes (only start one goroutine to consume), just like

for i := 0; i < 1; i++ {
		go func() {
			for {
				pull()
			}
		}()
	}

There the consume rate is very slow, every pull will block about 25s. But if modify the suspend param to false at

sysFlag := buildSysFlag(false, true, true, false)
the consume rate comes fast.

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions