Code

Refactor KafkaProducer#67

Code

Merged

FranzBusch merged 9 commits intoswift-server:mainswift-server/swift-kafka-client:mainfrom felixschlegel:fs-kafka-producer-remove-async-streamfelixschlegel/swift-kafka-client:fs-kafka-producer-remove-async-streamCopy head branch name to clipboardJul 3, 2023

+455-176

Commits

Commits on Jun 30, 2023

• Refactor KafkaProducer

  Show description for 1781dbb
  felixschlegel

  committed
  1781dbb

  Copy full SHA for 1781dbb

• * rename KafkaProducer.StateMachine.State.shutDown to .finished

  felixschlegel

  committed
  4bc4075

  Copy full SHA for 4bc4075

• Remove unused awaits

  felixschlegel

  committed
  7c53ee2

  Copy full SHA for 7c53ee2

• KafkaProducer: move logger out of state

  felixschlegel

  committed
  fc27677

  Copy full SHA for fc27677

• KafkaProducer: rename killPollLoop -> terminatePollLoop

  felixschlegel

  committed
  73169ae

  Copy full SHA for 73169ae

• Fix errors after rebase

  Show description for 6098576
  felixschlegel

  committed
  6098576

  Copy full SHA for 6098576

• Create wrapper for Kafka topic handle dict

  Show description for 387fc03
  felixschlegel

  committed
  387fc03

  Copy full SHA for 387fc03

• Own implementation of rd_kafka_flush()

  Show description for dd9ea2f
  felixschlegel

  committed
  dd9ea2f

  Copy full SHA for dd9ea2f

• Review Franz

  Show description for c9b4d03
  felixschlegel

  committed
  c9b4d03

  Copy full SHA for c9b4d03