test_class.declarator: props = new Properties()
test_class.modifier: private
test_class.original_string: private Properties props = new Properties();
test_class.type: Properties
test_class.var_name: props
test_class.declarator: streamsConfig
test_class.modifier: private
test_class.original_string: private StreamsConfig streamsConfig;
test_class.type: StreamsConfig
test_class.var_name: streamsConfig
test_class.file: streams/src/test/java/org/apache/kafka/streams/StreamsConfigTest.java
test_class.identifier: StreamsConfigTest
test_case.body: @Test
      public void testGetConsumerConfigs() throws Exception {
          Map<String, Object> returnedProps = streamsConfig.getConsumerConfigs(null, "example-application", "client");
          assertEquals(returnedProps.get(ConsumerConfig.CLIENT_ID_CONFIG), "client-consumer");
          assertEquals(returnedProps.get(ConsumerConfig.GROUP_ID_CONFIG), "example-application");
  
      }
test_case.class_method_signature: StreamsConfigTest.testGetConsumerConfigs()
test_case.full_signature: @Test public void testGetConsumerConfigs()
test_case.identifier: testGetConsumerConfigs
test_case.invocations: getConsumerConfigs assertEquals get assertEquals get
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testGetConsumerConfigs()
focal_class.declarator: CONFIG
focal_class.modifier: private static final
focal_class.original_string: private static final ConfigDef CONFIG;
focal_class.type: ConfigDef
focal_class.var_name: CONFIG
focal_class.declarator: STATE_DIR_CONFIG = "state.dir"
focal_class.modifier: public static final
focal_class.original_string: public static final String STATE_DIR_CONFIG = "state.dir";
focal_class.type: String
focal_class.var_name: STATE_DIR_CONFIG
focal_class.declarator: STATE_DIR_DOC = "Directory location for state store."
focal_class.modifier: private static final
focal_class.original_string: private static final String STATE_DIR_DOC = "Directory location for state store.";
focal_class.type: String
focal_class.var_name: STATE_DIR_DOC
focal_class.declarator: ZOOKEEPER_CONNECT_CONFIG = "zookeeper.connect"
focal_class.modifier: public static final
focal_class.original_string: public static final String ZOOKEEPER_CONNECT_CONFIG = "zookeeper.connect";
focal_class.type: String
focal_class.var_name: ZOOKEEPER_CONNECT_CONFIG
focal_class.declarator: ZOOKEEPER_CONNECT_DOC = "Zookeeper connect string for Kafka topics management."
focal_class.modifier: private static final
focal_class.original_string: private static final String ZOOKEEPER_CONNECT_DOC = "Zookeeper connect string for Kafka topics management.";
focal_class.type: String
focal_class.var_name: ZOOKEEPER_CONNECT_DOC
focal_class.declarator: COMMIT_INTERVAL_MS_CONFIG = "commit.interval.ms"
focal_class.modifier: public static final
focal_class.original_string: public static final String COMMIT_INTERVAL_MS_CONFIG = "commit.interval.ms";
focal_class.type: String
focal_class.var_name: COMMIT_INTERVAL_MS_CONFIG
focal_class.declarator: COMMIT_INTERVAL_MS_DOC = "The frequency with which to save the position of the processor."
focal_class.modifier: private static final
focal_class.original_string: private static final String COMMIT_INTERVAL_MS_DOC = "The frequency with which to save the position of the processor.";
focal_class.type: String
focal_class.var_name: COMMIT_INTERVAL_MS_DOC
focal_class.declarator: POLL_MS_CONFIG = "poll.ms"
focal_class.modifier: public static final
focal_class.original_string: public static final String POLL_MS_CONFIG = "poll.ms";
focal_class.type: String
focal_class.var_name: POLL_MS_CONFIG
focal_class.declarator: POLL_MS_DOC = "The amount of time in milliseconds to block waiting for input."
focal_class.modifier: private static final
focal_class.original_string: private static final String POLL_MS_DOC = "The amount of time in milliseconds to block waiting for input.";
focal_class.type: String
focal_class.var_name: POLL_MS_DOC
focal_class.declarator: NUM_STREAM_THREADS_CONFIG = "num.stream.threads"
focal_class.modifier: public static final
focal_class.original_string: public static final String NUM_STREAM_THREADS_CONFIG = "num.stream.threads";
focal_class.type: String
focal_class.var_name: NUM_STREAM_THREADS_CONFIG
focal_class.declarator: NUM_STREAM_THREADS_DOC = "The number of threads to execute stream processing."
focal_class.modifier: private static final
focal_class.original_string: private static final String NUM_STREAM_THREADS_DOC = "The number of threads to execute stream processing.";
focal_class.type: String
focal_class.var_name: NUM_STREAM_THREADS_DOC
focal_class.declarator: NUM_STANDBY_REPLICAS_CONFIG = "num.standby.replicas"
focal_class.modifier: public static final
focal_class.original_string: public static final String NUM_STANDBY_REPLICAS_CONFIG = "num.standby.replicas";
focal_class.type: String
focal_class.var_name: NUM_STANDBY_REPLICAS_CONFIG
focal_class.declarator: NUM_STANDBY_REPLICAS_DOC = "The number of standby replicas for each task."
focal_class.modifier: private static final
focal_class.original_string: private static final String NUM_STANDBY_REPLICAS_DOC = "The number of standby replicas for each task.";
focal_class.type: String
focal_class.var_name: NUM_STANDBY_REPLICAS_DOC
focal_class.declarator: BUFFERED_RECORDS_PER_PARTITION_CONFIG = "buffered.records.per.partition"
focal_class.modifier: public static final
focal_class.original_string: public static final String BUFFERED_RECORDS_PER_PARTITION_CONFIG = "buffered.records.per.partition";
focal_class.type: String
focal_class.var_name: BUFFERED_RECORDS_PER_PARTITION_CONFIG
focal_class.declarator: BUFFERED_RECORDS_PER_PARTITION_DOC = "The maximum number of records to buffer per partition."
focal_class.modifier: private static final
focal_class.original_string: private static final String BUFFERED_RECORDS_PER_PARTITION_DOC = "The maximum number of records to buffer per partition.";
focal_class.type: String
focal_class.var_name: BUFFERED_RECORDS_PER_PARTITION_DOC
focal_class.declarator: STATE_CLEANUP_DELAY_MS_CONFIG = "state.cleanup.delay.ms"
focal_class.modifier: public static final
focal_class.original_string: public static final String STATE_CLEANUP_DELAY_MS_CONFIG = "state.cleanup.delay.ms";
focal_class.type: String
focal_class.var_name: STATE_CLEANUP_DELAY_MS_CONFIG
focal_class.declarator: STATE_CLEANUP_DELAY_MS_DOC = "The amount of time in milliseconds to wait before deleting state when a partition has migrated."
focal_class.modifier: private static final
focal_class.original_string: private static final String STATE_CLEANUP_DELAY_MS_DOC = "The amount of time in milliseconds to wait before deleting state when a partition has migrated.";
focal_class.type: String
focal_class.var_name: STATE_CLEANUP_DELAY_MS_DOC
focal_class.declarator: TIMESTAMP_EXTRACTOR_CLASS_CONFIG = "timestamp.extractor"
focal_class.modifier: public static final
focal_class.original_string: public static final String TIMESTAMP_EXTRACTOR_CLASS_CONFIG = "timestamp.extractor";
focal_class.type: String
focal_class.var_name: TIMESTAMP_EXTRACTOR_CLASS_CONFIG
focal_class.declarator: TIMESTAMP_EXTRACTOR_CLASS_DOC = "Timestamp extractor class that implements the <code>TimestampExtractor</code> interface."
focal_class.modifier: private static final
focal_class.original_string: private static final String TIMESTAMP_EXTRACTOR_CLASS_DOC = "Timestamp extractor class that implements the <code>TimestampExtractor</code> interface.";
focal_class.type: String
focal_class.var_name: TIMESTAMP_EXTRACTOR_CLASS_DOC
focal_class.declarator: PARTITION_GROUPER_CLASS_CONFIG = "partition.grouper"
focal_class.modifier: public static final
focal_class.original_string: public static final String PARTITION_GROUPER_CLASS_CONFIG = "partition.grouper";
focal_class.type: String
focal_class.var_name: PARTITION_GROUPER_CLASS_CONFIG
focal_class.declarator: PARTITION_GROUPER_CLASS_DOC = "Partition grouper class that implements the <code>PartitionGrouper</code> interface."
focal_class.modifier: private static final
focal_class.original_string: private static final String PARTITION_GROUPER_CLASS_DOC = "Partition grouper class that implements the <code>PartitionGrouper</code> interface.";
focal_class.type: String
focal_class.var_name: PARTITION_GROUPER_CLASS_DOC
focal_class.declarator: APPLICATION_ID_CONFIG = "application.id"
focal_class.modifier: public static final
focal_class.original_string: public static final String APPLICATION_ID_CONFIG = "application.id";
focal_class.type: String
focal_class.var_name: APPLICATION_ID_CONFIG
focal_class.declarator: APPLICATION_ID_DOC = "An identifier for the stream processing application. Must be unique within the Kafka cluster. It is used as 1) the default client-id prefix, 2) the group-id for membership management, 3) the changelog topic prefix."
focal_class.modifier: public static final
focal_class.original_string: public static final String APPLICATION_ID_DOC = "An identifier for the stream processing application. Must be unique within the Kafka cluster. It is used as 1) the default client-id prefix, 2) the group-id for membership management, 3) the changelog topic prefix.";
focal_class.type: String
focal_class.var_name: APPLICATION_ID_DOC
focal_class.declarator: REPLICATION_FACTOR_CONFIG = "replication.factor"
focal_class.modifier: public static final
focal_class.original_string: public static final String REPLICATION_FACTOR_CONFIG = "replication.factor";
focal_class.type: String
focal_class.var_name: REPLICATION_FACTOR_CONFIG
focal_class.declarator: REPLICATION_FACTOR_DOC = "The replication factor for change log topics and repartition topics created by the stream processing application."
focal_class.modifier: public static final
focal_class.original_string: public static final String REPLICATION_FACTOR_DOC = "The replication factor for change log topics and repartition topics created by the stream processing application.";
focal_class.type: String
focal_class.var_name: REPLICATION_FACTOR_DOC
focal_class.declarator: KEY_SERDE_CLASS_CONFIG = "key.serde"
focal_class.modifier: public static final
focal_class.original_string: public static final String KEY_SERDE_CLASS_CONFIG = "key.serde";
focal_class.type: String
focal_class.var_name: KEY_SERDE_CLASS_CONFIG
focal_class.declarator: KEY_SERDE_CLASS_DOC = "Serializer / deserializer class for key that implements the <code>Serde</code> interface."
focal_class.modifier: public static final
focal_class.original_string: public static final String KEY_SERDE_CLASS_DOC = "Serializer / deserializer class for key that implements the <code>Serde</code> interface.";
focal_class.type: String
focal_class.var_name: KEY_SERDE_CLASS_DOC
focal_class.declarator: VALUE_SERDE_CLASS_CONFIG = "value.serde"
focal_class.modifier: public static final
focal_class.original_string: public static final String VALUE_SERDE_CLASS_CONFIG = "value.serde";
focal_class.type: String
focal_class.var_name: VALUE_SERDE_CLASS_CONFIG
focal_class.declarator: VALUE_SERDE_CLASS_DOC = "Serializer / deserializer class for value that implements the <code>Serde</code> interface."
focal_class.modifier: public static final
focal_class.original_string: public static final String VALUE_SERDE_CLASS_DOC = "Serializer / deserializer class for value that implements the <code>Serde</code> interface.";
focal_class.type: String
focal_class.var_name: VALUE_SERDE_CLASS_DOC
focal_class.declarator: METRICS_SAMPLE_WINDOW_MS_CONFIG = CommonClientConfigs.METRICS_SAMPLE_WINDOW_MS_CONFIG
focal_class.modifier: public static final
focal_class.original_string: public static final String METRICS_SAMPLE_WINDOW_MS_CONFIG = CommonClientConfigs.METRICS_SAMPLE_WINDOW_MS_CONFIG;
focal_class.type: String
focal_class.var_name: METRICS_SAMPLE_WINDOW_MS_CONFIG
focal_class.declarator: METRICS_NUM_SAMPLES_CONFIG = CommonClientConfigs.METRICS_NUM_SAMPLES_CONFIG
focal_class.modifier: public static final
focal_class.original_string: public static final String METRICS_NUM_SAMPLES_CONFIG = CommonClientConfigs.METRICS_NUM_SAMPLES_CONFIG;
focal_class.type: String
focal_class.var_name: METRICS_NUM_SAMPLES_CONFIG
focal_class.declarator: METRIC_REPORTER_CLASSES_CONFIG = CommonClientConfigs.METRIC_REPORTER_CLASSES_CONFIG
focal_class.modifier: public static final
focal_class.original_string: public static final String METRIC_REPORTER_CLASSES_CONFIG = CommonClientConfigs.METRIC_REPORTER_CLASSES_CONFIG;
focal_class.type: String
focal_class.var_name: METRIC_REPORTER_CLASSES_CONFIG
focal_class.declarator: BOOTSTRAP_SERVERS_CONFIG = CommonClientConfigs.BOOTSTRAP_SERVERS_CONFIG
focal_class.modifier: public static final
focal_class.original_string: public static final String BOOTSTRAP_SERVERS_CONFIG = CommonClientConfigs.BOOTSTRAP_SERVERS_CONFIG;
focal_class.type: String
focal_class.var_name: BOOTSTRAP_SERVERS_CONFIG
focal_class.declarator: CLIENT_ID_CONFIG = CommonClientConfigs.CLIENT_ID_CONFIG
focal_class.modifier: public static final
focal_class.original_string: public static final String CLIENT_ID_CONFIG = CommonClientConfigs.CLIENT_ID_CONFIG;
focal_class.type: String
focal_class.var_name: CLIENT_ID_CONFIG
focal_class.file: streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java
focal_class.identifier: StreamsConfig
focal_class.class_method_signature: StreamsConfig.StreamsConfig(Map<?, ?> props)
focal_class.full_signature: public  StreamsConfig(Map<?, ?> props)
focal_class.identifier: StreamsConfig
focal_class.modifiers: public
focal_class.parameters: (Map<?, ?> props)
focal_class.signature:  StreamsConfig(Map<?, ?> props)
focal_class.class_method_signature: StreamsConfig.getConsumerConfigs(StreamThread streamThread, String groupId, String clientId)
focal_class.full_signature: public Map<String, Object> getConsumerConfigs(StreamThread streamThread, String groupId, String clientId)
focal_class.identifier: getConsumerConfigs
focal_class.modifiers: public
focal_class.parameters: (StreamThread streamThread, String groupId, String clientId)
focal_class.return: Map<String, Object>
focal_class.signature: Map<String, Object> getConsumerConfigs(StreamThread streamThread, String groupId, String clientId)
focal_class.class_method_signature: StreamsConfig.getRestoreConsumerConfigs(String clientId)
focal_class.full_signature: public Map<String, Object> getRestoreConsumerConfigs(String clientId)
focal_class.identifier: getRestoreConsumerConfigs
focal_class.modifiers: public
focal_class.parameters: (String clientId)
focal_class.return: Map<String, Object>
focal_class.signature: Map<String, Object> getRestoreConsumerConfigs(String clientId)
focal_class.class_method_signature: StreamsConfig.getBaseConsumerConfigs()
focal_class.full_signature: private Map<String, Object> getBaseConsumerConfigs()
focal_class.identifier: getBaseConsumerConfigs
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: Map<String, Object>
focal_class.signature: Map<String, Object> getBaseConsumerConfigs()
focal_class.class_method_signature: StreamsConfig.getProducerConfigs(String clientId)
focal_class.full_signature: public Map<String, Object> getProducerConfigs(String clientId)
focal_class.identifier: getProducerConfigs
focal_class.modifiers: public
focal_class.parameters: (String clientId)
focal_class.return: Map<String, Object>
focal_class.signature: Map<String, Object> getProducerConfigs(String clientId)
focal_class.class_method_signature: StreamsConfig.removeStreamsSpecificConfigs(Map<String, Object> props)
focal_class.full_signature: private void removeStreamsSpecificConfigs(Map<String, Object> props)
focal_class.identifier: removeStreamsSpecificConfigs
focal_class.modifiers: private
focal_class.parameters: (Map<String, Object> props)
focal_class.return: void
focal_class.signature: void removeStreamsSpecificConfigs(Map<String, Object> props)
focal_class.class_method_signature: StreamsConfig.keySerde()
focal_class.full_signature: public Serde keySerde()
focal_class.identifier: keySerde
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: Serde
focal_class.signature: Serde keySerde()
focal_class.class_method_signature: StreamsConfig.valueSerde()
focal_class.full_signature: public Serde valueSerde()
focal_class.identifier: valueSerde
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: Serde
focal_class.signature: Serde valueSerde()
focal_class.class_method_signature: StreamsConfig.main(String[] args)
focal_class.full_signature: public static void main(String[] args)
focal_class.identifier: main
focal_class.modifiers: public static
focal_class.parameters: (String[] args)
focal_class.return: void
focal_class.signature: void main(String[] args)
focal_class.superclass: extends AbstractConfig
focal_method.body: public Map<String, Object> getConsumerConfigs(StreamThread streamThread, String groupId, String clientId) {
          Map<String, Object> props = getBaseConsumerConfigs();
  
          // add client id with stream client id prefix, and group id
          props.put(ConsumerConfig.GROUP_ID_CONFIG, groupId);
          props.put(CommonClientConfigs.CLIENT_ID_CONFIG, clientId + "-consumer");
  
          // add configs required for stream partition assignor
          props.put(StreamsConfig.InternalConfig.STREAM_THREAD_INSTANCE, streamThread);
          props.put(StreamsConfig.REPLICATION_FACTOR_CONFIG, getInt(REPLICATION_FACTOR_CONFIG));
          props.put(StreamsConfig.NUM_STANDBY_REPLICAS_CONFIG, getInt(NUM_STANDBY_REPLICAS_CONFIG));
          props.put(ConsumerConfig.PARTITION_ASSIGNMENT_STRATEGY_CONFIG, StreamPartitionAssignor.class.getName());
  
          if (!getString(ZOOKEEPER_CONNECT_CONFIG).equals(""))
              props.put(StreamsConfig.ZOOKEEPER_CONNECT_CONFIG, getString(ZOOKEEPER_CONNECT_CONFIG));
  
          return props;
      }
focal_method.class_method_signature: StreamsConfig.getConsumerConfigs(StreamThread streamThread, String groupId, String clientId)
focal_method.full_signature: public Map<String, Object> getConsumerConfigs(StreamThread streamThread, String groupId, String clientId)
focal_method.identifier: getConsumerConfigs
focal_method.invocations: getBaseConsumerConfigs put put put put getInt put getInt put getName equals getString put getString
focal_method.modifiers: public
focal_method.parameters: (StreamThread streamThread, String groupId, String clientId)
focal_method.return: Map<String, Object>
focal_method.signature: Map<String, Object> getConsumerConfigs(StreamThread streamThread, String groupId, String clientId)