You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
The current extensión methods that allow transforming to and from CloudEvents into Kafka messages expects always messages of type Message<string?, byte[]> where the first generic template parameter is the type of Key in the Kafka messages.
When using the KafkaConsumer or producer it is usual to use the types "Confluent.Kafka.Ignore" or "Confluent.Kafka.Null" too that would handle messages like the following:
Message<Confluent.Kafka.Ignore, byte[]>
Message<Confluent.Kafka.Null, byte[]>
The text was updated successfully, but these errors were encountered:
This is something I would be unable to take on myself, not being familiar with Kafka. (I basically inherited the current code to maintain.) I'd welcome a pull request that addresses the concern, preferably without any breaking changes to the existing API.
Abuntxa
pushed a commit
to Abuntxa/sdk-csharp
that referenced
this issue
Sep 26, 2024
The current extensión methods that allow transforming to and from CloudEvents into Kafka messages expects always messages of type Message<string?, byte[]> where the first generic template parameter is the type of Key in the Kafka messages.
When using the KafkaConsumer or producer it is usual to use the types "Confluent.Kafka.Ignore" or "Confluent.Kafka.Null" too that would handle messages like the following:
Message<Confluent.Kafka.Ignore, byte[]>
Message<Confluent.Kafka.Null, byte[]>
The text was updated successfully, but these errors were encountered: