diff --git a/implementations/rust/ockam/ockam_api/src/kafka/protocol_aware/tests.rs b/implementations/rust/ockam/ockam_api/src/kafka/protocol_aware/tests.rs index 6ad4bb153ae..87d08845a2b 100644 --- a/implementations/rust/ockam/ockam_api/src/kafka/protocol_aware/tests.rs +++ b/implementations/rust/ockam/ockam_api/src/kafka/protocol_aware/tests.rs @@ -41,7 +41,7 @@ mod test { Resource::new("arbitrary-resource-name", ResourceType::KafkaConsumer), Action::HandleMessage, Env::new(), - handle.node_manager.identifier(), + Some(handle.node_manager.identifier()), ); let producer_policy_access_control = policies.make_policy_access_control( @@ -49,7 +49,7 @@ mod test { Resource::new("arbitrary-resource-name", ResourceType::KafkaProducer), Action::HandleMessage, Env::new(), - handle.node_manager.identifier(), + Some(handle.node_manager.identifier()), ); let secure_channel_controller = KafkaSecureChannelControllerImpl::new(