Sets the consumer properties.
@param consumerProperties
@return
551678
public KafkaEndpointBuilder consumerProperties(Map<String, Object> consumerProperties) {
        endpoint.getEndpointConfiguration().setConsumerProperties(consumerProperties);
        return this;
    }
32894
protected void enableConsumers(List<ConsumerHolder> consumerHolders) throws IOException {
        checkPreconditions(consumerHolders);
        try {
            for (ConsumerHolder consumerHolder : consumerHolders) {
                consumerHolder.enable();
            }
        } catch (IOException e) {
            LOGGER.error("Failed to enable consumers - disabling already enabled consumers");
            disableConsumers(consumerHolders);
            throw e;
        }
    }
1246103
public Properties getFeatureProperties() {
		Properties properties = new Properties();
		for (String name : features.keySet()) {
			properties.setProperty(name, features.get(name).spec());
		}
		return properties;
	}
1298936
private Properties getConsumerProperties(NotificationType type) {
        // find the configured group id for the given notification type

        String groupId = properties.getProperty(type.toString().toLowerCase() + "." + CONSUMER_GROUP_ID_PROPERTY);
        if (StringUtils.isEmpty(groupId)) {
            throw new IllegalStateException("No configuration group id set for the notification type " + type);
        }

        Properties consumerProperties = new Properties();
        consumerProperties.putAll(properties);
        consumerProperties.put(ConsumerConfig.GROUP_ID_CONFIG, groupId);

        LOG.info("Consumer property: atlas.kafka.enable.auto.commit: {}", consumerProperties.getProperty("enable.auto.commit"));
        return consumerProperties;
    }
312058
@SuppressWarnings("unchecked")
    public void forEach(final Consumer<V> consumer)
    {
        for (final Object value : values)
        {
            if (null != value)
            {
                consumer.accept((V)value);
            }
        }
    }
43388
public void setProperties( Map<String, Object> properties )
    {
        Introspector introspector = new Introspector( target.getClass(), new PropertyComparator() );
        for (Map.Entry<String,Object> property : properties.entrySet())
        {
            Method setter = introspector.getSetter( property.getKey() );
            if (setter != null) invoke( setter, property.getValue() );
        }
    }
1220328
public java.util.List<Consumer> getConsumers() {
        if (consumers == null) {
            consumers = new com.amazonaws.internal.SdkInternalList<Consumer>();
        }
        return consumers;
    }
316225
public GlobalJmxStatisticsConfigurationBuilder withProperties(Properties properties) {
      attributes.attribute(PROPERTIES).set(new TypedProperties(properties));
      return this;
   }
657499
public KafkaEndpointBuilder producerProperties(Map<String, Object> producerProperties) {
        endpoint.getEndpointConfiguration().setProducerProperties(producerProperties);
        return this;
    }
610253
public void setProperties(Properties properties) {
		ttlInSeconds = Integer.valueOf(properties.getProperty("ttlInSeconds", "" + ttlInSeconds));
		cleanupInterval = Integer.valueOf(properties.getProperty("cleanup_interval", "" + cleanupInterval));
	}
50796
public final ThreadProperties threadProperties() {
        ThreadProperties threadProperties = this.threadProperties;
        if (threadProperties == null) {
            Thread thread = this.thread;
            if (thread == null) {
                assert !inEventLoop();
                submit(NOOP_TASK).syncUninterruptibly();
                thread = this.thread;
                assert thread != null;
            }

            threadProperties = new DefaultThreadProperties(thread);
            if (!PROPERTIES_UPDATER.compareAndSet(this, null, threadProperties)) {
                threadProperties = this.threadProperties;
            }
        }

        return threadProperties;
    }
846789
public void setProperties(Map<String, Object> properties)
    {
        Record recUserRegistration = this.getUserRegistration();
        ((PropertiesField)recUserRegistration.getField(UserRegistrationModel.PROPERTIES)).setProperties(properties);
    }
1342757
@Override
    public ConsumerManager createConsumerManager()
    {
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.entry(tc, "createConsumerManager");

        ConsumerDispatcher consumerDispatcher = (ConsumerDispatcher) getOutputHandler();
        if (consumerDispatcher == null)
        {
            consumerDispatcher = new ConsumerDispatcher(destinationHandler, this, new ConsumerDispatcherState());
            setOutputHandler(consumerDispatcher);
        }

        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.exit(tc, "createConsumerManager", consumerDispatcher);
        return consumerDispatcher;
    }
277412
@Nonnull
	public static <T> Consumer<T> consumerFrom(Consumer<ConsumerBuilder<T>> buildingFunction) {
		ConsumerBuilder builder = new ConsumerBuilder();
		buildingFunction.accept(builder);
		return builder.build();
	}
352417
public void putProperties(Map<String, String> properties) {
		for (Map.Entry<String, String> property : properties.entrySet()) {
			put(property.getKey(), property.getValue());
		}
	}
544737
public void setProperties(Map<String, Object> properties)
    {
        if (this.getParentRecordOwner() != null)
            this.getParentRecordOwner().setProperties(properties);
    }
1184614
public void setDefaultProperties(Properties defaultProperties) {
		this.defaultProperties = new HashMap<>();
		for (Object key : Collections.list(defaultProperties.propertyNames())) {
			this.defaultProperties.put((String) key, defaultProperties.get(key));
		}
	}