Skip to content

[Feature Request]: Add timestamp argument to produce #653

Description

@vtomskih

Is your request related to a problem you have?

Confluent.Kafka producer allows to provide custom timestamp, but now we always use default Timestamp = Timestamp.Default. We want to be able to specify our own event timestamp.

Describe the solution you'd like

Add overloads to IMessageProducer with timestamp:

    Task<DeliveryResult<byte[], byte[]>> ProduceAsync(
        string topic,
        object messageKey,
        object messageValue,
        IMessageHeaders headers = null,
        int? partition = null,
        Timestamp timestamp = Timestamp.Default);

Metadata

Metadata

Assignees

No one assigned

    Labels

    enhancementNew feature or request

    Type

    No type

    Projects

    No projects

      Milestone

      No milestone

      Relationships

      None yet

      Development

      No branches or pull requests

      Issue actions