apache-kafka - 使用 kafka 端点提高事件中心的性能

Question

我们正在使用融合的 Kafka 库 (1.5.1) 评估带有 Kafka 端点的 azure 事件中心，并且我们观察到高 RTT（平均延迟）、消费者获取周期时间，有时再平衡计数也会增加。这些指标使用统计处理程序记录。

以下是消费者配置：

var consumerConfig = new ConsumerConfig
{
BootstrapServers = config.Broker,
SaslUsername = config.SaslUsername,
SaslPassword = config.SaslPassword,
SaslMechanism = SaslMechanism.Plain,
SecurityProtocol = SecurityProtocol.SaslSsl,
AutoOffsetReset = AutoOffsetReset.Earliest,
GroupId = "sample-eventhub",
EnableAutoCommit = false,
TopicMetadataRefreshIntervalMs = 200000,
ConsumeResultFields = "timestamp,topic",
QueuedMaxMessagesKbytes = 5,
StatisticsIntervalMs = 60000,
SocketKeepaliveEnable = true,
SessionTimeoutMs = 60000
};

注意：消费者获取周期时间较长的原因之一是消息提交 (_streamConsumer.Commit) 花费的时间比应用程序处理消息的时间要长。

相同的代码和配置适用于 Kafka 代理，但不适用于带有 Kafka 端点的事件中心。您能否分享您的建议以提高性能？