Skip to content
This repository was archived by the owner on Jan 24, 2024. It is now read-only.

[BUG] close channel with pending responses #1866

@xuesongxs

Description

@xuesongxs

Describe the bug
Pulsar v2.8.1, KOP v2.8.1.30

To Reproduce
Steps to reproduce the behavior:

  1. Start kop with broker
  2. bin/kafka-producer-perf-test.sh --topic test-topic --num-records 1000000 --record-size 1000 --throughput -1 --producer-props bootstrap.servers=XXXX:9092
  3. broker.log
    4.The rate at which Kafka producers write to topics is unstable, and connections are closed every 1 minute
    image
  4. See error
    image

Expected behavior
The rate at which kafka producers write to the topic is stable, and the connection between kafka producers and kop will not be closed.

Screenshots
If applicable, add screenshots to help explain your problem.

Additional context
Add any other context about the problem here.

Metadata

Metadata

Assignees

No one assigned

    Labels

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions