lbradstreet commented on pull request #10704:
URL: https://github.com/apache/kafka/pull/10704#issuecomment-849144204
@ijuma I figured out the cause with some state change checks. The problem is
that we're passing a recording map through to the channel/principal builders,
and the recording map updates ignore.
```
at
org.apache.kafka.clients.producer.ProducerConfig.ignore(ProducerConfig.java:569)
at
org.apache.kafka.common.config.AbstractConfig$RecordingMap.get(AbstractConfig.java:638)
at
org.apache.kafka.common.network.ChannelBuilders.createPrincipalBuilder(ChannelBuilders.java:242)
at
org.apache.kafka.common.network.PlaintextChannelBuilder$PlaintextAuthenticator.<init>(PlaintextChannelBuilder.java:96)
at
org.apache.kafka.common.network.PlaintextChannelBuilder$PlaintextAuthenticator.<init>(PlaintextChannelBuilder.java:89)
at
org.apache.kafka.common.network.PlaintextChannelBuilder.lambda$buildChannel$0(PlaintextChannelBuilder.java:66)
at
org.apache.kafka.common.network.KafkaChannel.<init>(KafkaChannel.java:174)
at
org.apache.kafka.common.network.KafkaChannel.<init>(KafkaChannel.java:164)
at
org.apache.kafka.common.network.PlaintextChannelBuilder.buildChannel(PlaintextChannelBuilder.java:79)
at
org.apache.kafka.common.network.PlaintextChannelBuilder.buildChannel(PlaintextChannelBuilder.java:67)
at
org.apache.kafka.common.network.Selector.buildAndAttachKafkaChannel(Selector.java:356)
at
org.apache.kafka.common.network.Selector.registerChannel(Selector.java:347)
at org.apache.kafka.common.network.Selector.connect(Selector.java:274)
at
org.apache.kafka.clients.NetworkClient.initiateConnect(NetworkClient.java:1097)
at
org.apache.kafka.clients.NetworkClient.access$700(NetworkClient.java:87)
at
org.apache.kafka.clients.NetworkClient$DefaultMetadataUpdater.maybeUpdate(NetworkClient.java:1276)
at
org.apache.kafka.clients.NetworkClient$DefaultMetadataUpdater.maybeUpdate(NetworkClient.java:1164)
at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:637)
at
org.apache.kafka.clients.producer.internals.Sender.runOnce(Sender.java:327)
at
org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:242)
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
