KafkaConsumerRecord

public struct KafkaConsumerRecord: Codable

The message returned by a KafkaConsumer polling a broker.

  • The message value if it can be utf8 decoded to a String.

    Declaration

    Swift

    public let value: String?

  • The message value as raw data.

    Declaration

    Swift

    public let valueData: Data
  • key

    The message key if it can be utf8 decoded to a String.

    Declaration

    Swift

    public let key: String?

  • The message key as raw data.

    Declaration

    Swift

    public let keyData: Data?

  • The message offset.

    Declaration

    Swift

    public let offset: Int

  • The topic that the message was consumed from.

    Declaration

    Swift

    public let topic: String

  • The partition that the message was consumed from.

    Declaration

    Swift

    public let partition: Int