Skip to content

Commit

Permalink
operator: rpk: Convert KafkaAPI to NamedAuthNSocketAddress
Browse files Browse the repository at this point in the history
Signed-off-by: Ben Pope <ben@redpanda.com>
  • Loading branch information
BenPope committed Jul 19, 2022
1 parent e4a8712 commit beee246
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions pkg/resources/configmap.go
Original file line number Diff line number Diff line change
Expand Up @@ -223,15 +223,15 @@ func (r *ConfigMapResource) CreateConfiguration(
cr := &cfg.NodeConfiguration.Redpanda

internalListener := r.pandaCluster.InternalListener()
cr.KafkaAPI = []config.NamedSocketAddress{} // we don't want to inherit default kafka port
cr.KafkaAPI = append(cr.KafkaAPI, config.NamedSocketAddress{
cr.KafkaAPI = []config.NamedAuthNSocketAddress{} // we don't want to inherit default kafka port
cr.KafkaAPI = append(cr.KafkaAPI, config.NamedAuthNSocketAddress{
Address: "0.0.0.0",
Port: internalListener.Port,
Name: InternalListenerName,
})

if r.pandaCluster.ExternalListener() != nil {
cr.KafkaAPI = append(cr.KafkaAPI, config.NamedSocketAddress{
cr.KafkaAPI = append(cr.KafkaAPI, config.NamedAuthNSocketAddress{
Address: "0.0.0.0",
Port: calculateExternalPort(internalListener.Port, r.pandaCluster.ExternalListener().Port),
Name: ExternalListenerName,
Expand Down

0 comments on commit beee246

Please sign in to comment.