Skip to content

KafkaAttribute.MaxMessageBytes is never used in KafkaProducerFactory #172

@shaunco

Description

@shaunco

It is currently impossible to produce messages over 1MB because KafkaAttribute.MaxMessageBytes is never used in KafkaProducerFactory. MaxMessageBytes is also not exposed via KafkaOptions, so I can't set it in host.json either.

Additionally, MaxMessageBytes can't be set directly as an attribute:

                       [Kafka(@"%Merge_Broker%",
                               @"%Merge_TopicName%",
                               MaxMessageBytes = 999999999,  // <-------
                               Protocol = BrokerProtocol.Plaintext,
                               AuthenticationMode = BrokerAuthenticationMode.NotSet,
                               SslCaLocation = "%Merge_SslCaLocation%")] IAsyncCollector<KafkaEventData<string>> collector,

Because int? is not a valid attribute type in C#.

Metadata

Metadata

Assignees

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