src-java/floodlight-service/floodlight-modules/src/main/java/org/openkilda/floodlight/KafkaChannelConfig.java
/**
     * Returns Kafka properties built with the configuration data for Consumer.
     */
Returns Kafka properties built with the configuration data for Consumer.
Returns Kafka properties built with the configuration data for Consumer .
default Properties consumerProperties() {
        Properties properties = new Properties();
        properties.put("bootstrap.servers", getBootstrapServers());
        properties.put("group.id", getGroupId());
        properties.put("session.timeout.ms", "30000");
        properties.put("enable.auto.commit", "false");
        properties.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
        properties.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
        properties.put(ConsumerConfig.INTERCEPTOR_CLASSES_CONFIG, VersioningConsumerInterceptor.class.getName());
        properties.put(CONSUMER_COMPONENT_NAME_PROPERTY, ZK_COMPONENT_NAME);
        properties.put(CONSUMER_RUN_ID_PROPERTY, getFloodlightRegion());
        properties.put(CONSUMER_ZOOKEEPER_CONNECTION_STRING_PROPERTY, getZooKeeperConnectString());
        properties.put(CONSUMER_ZOOKEEPER_RECONNECTION_DELAY_PROPERTY, Long.toString(getZooKeeperReconnectDelayMs()));
        return properties;
    }
default Properties consumerProperties ( ) { Properties properties = new Properties ( ) ; properties . put ( "bootstrap.servers" , getBootstrapServers ( ) ) ; properties . put ( "group.id" , getGroupId ( ) ) ; properties . put ( "session.timeout.ms" , "30000" ) ; properties . put ( "enable.auto.commit" , "false" ) ; properties . put ( "key.deserializer" , "org.apache.kafka.common.serialization.StringDeserializer" ) ; properties . put ( "value.deserializer" , "org.apache.kafka.common.serialization.StringDeserializer" ) ; properties . put ( ConsumerConfig . INTERCEPTOR_CLASSES_CONFIG , VersioningConsumerInterceptor . class . getName ( ) ) ; properties . put ( CONSUMER_COMPONENT_NAME_PROPERTY , ZK_COMPONENT_NAME ) ; properties . put ( CONSUMER_RUN_ID_PROPERTY , getFloodlightRegion ( ) ) ; properties . put ( CONSUMER_ZOOKEEPER_CONNECTION_STRING_PROPERTY , getZooKeeperConnectString ( ) ) ; properties . put ( CONSUMER_ZOOKEEPER_RECONNECTION_DELAY_PROPERTY , Long . toString ( getZooKeeperReconnectDelayMs ( ) ) ) ; return properties ; }
Returns Kafka properties built with the configuration data for Consumer.
Returns Kafka properties built with the configuration data for Consumer .