@Test
public void testSecurityProtocol_SASL_PLAINTEXT() {

  Properties kafkaProps = new Properties();
  kafkaProps.put(
      CommonClientConfigs.SECURITY_PROTOCOL_CONFIG, SecurityProtocol.SASL_PLAINTEXT.name);
  KafkaSSLUtil.addGlobalSSLParameters(kafkaProps);
  assertNoSSLParameters(kafkaProps);
}