Code

Various BaseProducer::flush fixes#748

Code

Merged

davidblewett merged 15 commits intomasterfede1024/rust-rdkafka:masterfrom davidblewett/producer-flushfede1024/rust-rdkafka:davidblewett/producer-flushCopy head branch name to clipboardDec 12, 2024

+90-34

Commits

Commits on Dec 5, 2024

• Refactor BaseProducer::poll to not return early, but instead

  Show description for c28c5ac
  davidblewett

  committed
  c28c5ac

  Copy full SHA for c28c5ac

Commits on Dec 10, 2024

• Simplify and rely on cast truncation.

  davidblewett

  committed
  3f2b5b9

  Copy full SHA for 3f2b5b9

• Fix logic error so that we always poll at least once even when

  Show description for 204dbe2
  davidblewett

  committed
  204dbe2

  Copy full SHA for 204dbe2

• Introduce Deadline type to simplify BaseProducer::flush and

  Show description for 36d4ebf
  davidblewett

  committed
  36d4ebf

  Copy full SHA for 36d4ebf

Commits on Dec 11, 2024

• Add From<Timeout> impl for Deadline

  davidblewett

  committed
  25951bf

  Copy full SHA for 25951bf

• Ensure we always call poll_event at least once, even if we have

  Show description for 1957d2f
  davidblewett

  committed
  1957d2f

  Copy full SHA for 1957d2f

• Allow Deadline to express Timeout::Never losslessly.

  davidblewett

  committed
  c4e1552

  Copy full SHA for c4e1552

Commits on Dec 12, 2024

• Refactor poll loop to be more idiomatic.

  davidblewett

  committed
  00e64ed

  Copy full SHA for 00e64ed

• Centralize clamping logic to Deadline.

  davidblewett

  committed
  68ed906

  Copy full SHA for 68ed906

• Remove extraneous From impl.

  davidblewett

  committed
  dcd606b

  Copy full SHA for dcd606b

• Simplify BaseProducer::poll to rely on From impl.

  davidblewett

  committed
  ac574f2

  Copy full SHA for ac574f2

• Don't block forever in poll when flushing.

  davidblewett

  committed
  2672739

  Copy full SHA for 2672739

• Remove this clamp, in favor of relying on remaining_millis_i32.

  davidblewett

  committed
  ab7b4af

  Copy full SHA for ab7b4af

• Ensure we always poll even if we get a timeout from flush.

  davidblewett

  committed
  840c098

  Copy full SHA for 840c098

• Update changelog reflecting behavior change in BaseProducer::poll.

  davidblewett

  committed
  ad3e065

  Copy full SHA for ad3e065