test_class.declarator: keyDeserializer = new ByteArrayDeserializer()
test_class.modifier: private final
test_class.original_string: private final Deserializer keyDeserializer = new ByteArrayDeserializer();
test_class.type: Deserializer
test_class.var_name: keyDeserializer
test_class.declarator: valueDeserializer = new StringDeserializer()
test_class.modifier: private final
test_class.original_string: private final Deserializer valueDeserializer = new StringDeserializer();
test_class.type: Deserializer
test_class.var_name: valueDeserializer
test_class.declarator: keyDeserializerClassName = keyDeserializer.getClass().getName()
test_class.modifier: private final
test_class.original_string: private final String keyDeserializerClassName = keyDeserializer.getClass().getName();
test_class.type: String
test_class.var_name: keyDeserializerClassName
test_class.declarator: valueDeserializerClassName = valueDeserializer.getClass().getName()
test_class.modifier: private final
test_class.original_string: private final String valueDeserializerClassName = valueDeserializer.getClass().getName();
test_class.type: String
test_class.var_name: valueDeserializerClassName
test_class.declarator: keyDeserializerClass = keyDeserializer.getClass()
test_class.modifier: private final
test_class.original_string: private final Object keyDeserializerClass = keyDeserializer.getClass();
test_class.type: Object
test_class.var_name: keyDeserializerClass
test_class.declarator: valueDeserializerClass = valueDeserializer.getClass()
test_class.modifier: private final
test_class.original_string: private final Object valueDeserializerClass = valueDeserializer.getClass();
test_class.type: Object
test_class.var_name: valueDeserializerClass
test_class.file: clients/src/test/java/org/apache/kafka/clients/consumer/ConsumerConfigTest.java
test_class.identifier: ConsumerConfigTest
test_case.body: @Test
      public void testDeserializerToMapConfig() {
          Map<String, Object> configs = new HashMap<>();
          configs.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, keyDeserializerClass);
          configs.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, valueDeserializerClass);
          Map<String, Object> newConfigs = ConsumerConfig.addDeserializerToConfig(configs, null, null);
          assertEquals(newConfigs.get(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG), keyDeserializerClass);
          assertEquals(newConfigs.get(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG), valueDeserializerClass);
  
          configs.clear();
          configs.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, valueDeserializerClass);
          newConfigs = ConsumerConfig.addDeserializerToConfig(configs, keyDeserializer, null);
          assertEquals(newConfigs.get(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG), keyDeserializerClass);
          assertEquals(newConfigs.get(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG), valueDeserializerClass);
  
          configs.clear();
          configs.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, keyDeserializerClass);
          newConfigs = ConsumerConfig.addDeserializerToConfig(configs, null, valueDeserializer);
          assertEquals(newConfigs.get(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG), keyDeserializerClass);
          assertEquals(newConfigs.get(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG), valueDeserializerClass);
  
          configs.clear();
          newConfigs = ConsumerConfig.addDeserializerToConfig(configs, keyDeserializer, valueDeserializer);
          assertEquals(newConfigs.get(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG), keyDeserializerClass);
          assertEquals(newConfigs.get(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG), valueDeserializerClass);
      }
test_case.class_method_signature: ConsumerConfigTest.testDeserializerToMapConfig()
test_case.full_signature: @Test public void testDeserializerToMapConfig()
test_case.identifier: testDeserializerToMapConfig
test_case.invocations: put put addDeserializerToConfig assertEquals get assertEquals get clear put addDeserializerToConfig assertEquals get assertEquals get clear put addDeserializerToConfig assertEquals get assertEquals get clear addDeserializerToConfig assertEquals get assertEquals get
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testDeserializerToMapConfig()
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: GROUP_ID_CONFIG = "group.id"
focal_class.modifier: public static final
focal_class.original_string: public static final String GROUP_ID_CONFIG = "group.id";
focal_class.type: String
focal_class.var_name: GROUP_ID_CONFIG
focal_class.declarator: GROUP_ID_DOC = "A unique string that identifies the consumer group this consumer belongs to. This property is required if the consumer uses either the group management functionality by using <code>subscribe(topic)</code> or the Kafka-based offset management strategy."
focal_class.modifier: private static final
focal_class.original_string: private static final String GROUP_ID_DOC = "A unique string that identifies the consumer group this consumer belongs to. This property is required if the consumer uses either the group management functionality by using <code>subscribe(topic)</code> or the Kafka-based offset management strategy.";
focal_class.type: String
focal_class.var_name: GROUP_ID_DOC
focal_class.declarator: MAX_POLL_RECORDS_CONFIG = "max.poll.records"
focal_class.modifier: public static final
focal_class.original_string: public static final String MAX_POLL_RECORDS_CONFIG = "max.poll.records";
focal_class.type: String
focal_class.var_name: MAX_POLL_RECORDS_CONFIG
focal_class.declarator: MAX_POLL_RECORDS_DOC = "The maximum number of records returned in a single call to poll()."
focal_class.modifier: private static final
focal_class.original_string: private static final String MAX_POLL_RECORDS_DOC = "The maximum number of records returned in a single call to poll().";
focal_class.type: String
focal_class.var_name: MAX_POLL_RECORDS_DOC
focal_class.declarator: SESSION_TIMEOUT_MS_CONFIG = "session.timeout.ms"
focal_class.modifier: public static final
focal_class.original_string: public static final String SESSION_TIMEOUT_MS_CONFIG = "session.timeout.ms";
focal_class.type: String
focal_class.var_name: SESSION_TIMEOUT_MS_CONFIG
focal_class.declarator: SESSION_TIMEOUT_MS_DOC = "The timeout used to detect failures when using Kafka's " +
              "group management facilities. When a consumer's heartbeat is not received within the session timeout, " +
              "the broker will mark the consumer as failed and rebalance the group. Since heartbeats are sent only " +
              "when poll() is invoked, a higher session timeout allows more time for message processing in the consumer's " +
              "poll loop at the cost of a longer time to detect hard failures. See also <code>" + MAX_POLL_RECORDS_CONFIG + "</code> for " +
              "another option to control the processing time in the poll loop. Note that the value must be in the " +
              "allowable range as configured in the broker configuration by <code>group.min.session.timeout.ms</code> " +
              "and <code>group.max.session.timeout.ms</code>."
focal_class.modifier: private static final
focal_class.original_string: private static final String SESSION_TIMEOUT_MS_DOC = "The timeout used to detect failures when using Kafka's " +
              "group management facilities. When a consumer's heartbeat is not received within the session timeout, " +
              "the broker will mark the consumer as failed and rebalance the group. Since heartbeats are sent only " +
              "when poll() is invoked, a higher session timeout allows more time for message processing in the consumer's " +
              "poll loop at the cost of a longer time to detect hard failures. See also <code>" + MAX_POLL_RECORDS_CONFIG + "</code> for " +
              "another option to control the processing time in the poll loop. Note that the value must be in the " +
              "allowable range as configured in the broker configuration by <code>group.min.session.timeout.ms</code> " +
              "and <code>group.max.session.timeout.ms</code>.";
focal_class.type: String
focal_class.var_name: SESSION_TIMEOUT_MS_DOC
focal_class.declarator: HEARTBEAT_INTERVAL_MS_CONFIG = "heartbeat.interval.ms"
focal_class.modifier: public static final
focal_class.original_string: public static final String HEARTBEAT_INTERVAL_MS_CONFIG = "heartbeat.interval.ms";
focal_class.type: String
focal_class.var_name: HEARTBEAT_INTERVAL_MS_CONFIG
focal_class.declarator: HEARTBEAT_INTERVAL_MS_DOC = "The expected time between heartbeats to the consumer coordinator when using Kafka's group management facilities. Heartbeats are used to ensure that the consumer's session stays active and to facilitate rebalancing when new consumers join or leave the group. The value must be set lower than <code>session.timeout.ms</code>, but typically should be set no higher than 1/3 of that value. It can be adjusted even lower to control the expected time for normal rebalances."
focal_class.modifier: private static final
focal_class.original_string: private static final String HEARTBEAT_INTERVAL_MS_DOC = "The expected time between heartbeats to the consumer coordinator when using Kafka's group management facilities. Heartbeats are used to ensure that the consumer's session stays active and to facilitate rebalancing when new consumers join or leave the group. The value must be set lower than <code>session.timeout.ms</code>, but typically should be set no higher than 1/3 of that value. It can be adjusted even lower to control the expected time for normal rebalances.";
focal_class.type: String
focal_class.var_name: HEARTBEAT_INTERVAL_MS_DOC
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: ENABLE_AUTO_COMMIT_CONFIG = "enable.auto.commit"
focal_class.modifier: public static final
focal_class.original_string: public static final String ENABLE_AUTO_COMMIT_CONFIG = "enable.auto.commit";
focal_class.type: String
focal_class.var_name: ENABLE_AUTO_COMMIT_CONFIG
focal_class.declarator: ENABLE_AUTO_COMMIT_DOC = "If true the consumer's offset will be periodically committed in the background."
focal_class.modifier: private static final
focal_class.original_string: private static final String ENABLE_AUTO_COMMIT_DOC = "If true the consumer's offset will be periodically committed in the background.";
focal_class.type: String
focal_class.var_name: ENABLE_AUTO_COMMIT_DOC
focal_class.declarator: AUTO_COMMIT_INTERVAL_MS_CONFIG = "auto.commit.interval.ms"
focal_class.modifier: public static final
focal_class.original_string: public static final String AUTO_COMMIT_INTERVAL_MS_CONFIG = "auto.commit.interval.ms";
focal_class.type: String
focal_class.var_name: AUTO_COMMIT_INTERVAL_MS_CONFIG
focal_class.declarator: AUTO_COMMIT_INTERVAL_MS_DOC = "The frequency in milliseconds that the consumer offsets are auto-committed to Kafka if <code>enable.auto.commit</code> is set to <code>true</code>."
focal_class.modifier: private static final
focal_class.original_string: private static final String AUTO_COMMIT_INTERVAL_MS_DOC = "The frequency in milliseconds that the consumer offsets are auto-committed to Kafka if <code>enable.auto.commit</code> is set to <code>true</code>.";
focal_class.type: String
focal_class.var_name: AUTO_COMMIT_INTERVAL_MS_DOC
focal_class.declarator: PARTITION_ASSIGNMENT_STRATEGY_CONFIG = "partition.assignment.strategy"
focal_class.modifier: public static final
focal_class.original_string: public static final String PARTITION_ASSIGNMENT_STRATEGY_CONFIG = "partition.assignment.strategy";
focal_class.type: String
focal_class.var_name: PARTITION_ASSIGNMENT_STRATEGY_CONFIG
focal_class.declarator: PARTITION_ASSIGNMENT_STRATEGY_DOC = "The class name of the partition assignment strategy that the client will use to distribute partition ownership amongst consumer instances when group management is used"
focal_class.modifier: private static final
focal_class.original_string: private static final String PARTITION_ASSIGNMENT_STRATEGY_DOC = "The class name of the partition assignment strategy that the client will use to distribute partition ownership amongst consumer instances when group management is used";
focal_class.type: String
focal_class.var_name: PARTITION_ASSIGNMENT_STRATEGY_DOC
focal_class.declarator: AUTO_OFFSET_RESET_CONFIG = "auto.offset.reset"
focal_class.modifier: public static final
focal_class.original_string: public static final String AUTO_OFFSET_RESET_CONFIG = "auto.offset.reset";
focal_class.type: String
focal_class.var_name: AUTO_OFFSET_RESET_CONFIG
focal_class.declarator: AUTO_OFFSET_RESET_DOC = "What to do when there is no initial offset in Kafka or if the current offset does not exist any more on the server (e.g. because that data has been deleted): <ul><li>earliest: automatically reset the offset to the earliest offset<li>latest: automatically reset the offset to the latest offset</li><li>none: throw exception to the consumer if no previous offset is found for the consumer's group</li><li>anything else: throw exception to the consumer.</li></ul>"
focal_class.modifier: public static final
focal_class.original_string: public static final String AUTO_OFFSET_RESET_DOC = "What to do when there is no initial offset in Kafka or if the current offset does not exist any more on the server (e.g. because that data has been deleted): <ul><li>earliest: automatically reset the offset to the earliest offset<li>latest: automatically reset the offset to the latest offset</li><li>none: throw exception to the consumer if no previous offset is found for the consumer's group</li><li>anything else: throw exception to the consumer.</li></ul>";
focal_class.type: String
focal_class.var_name: AUTO_OFFSET_RESET_DOC
focal_class.declarator: FETCH_MIN_BYTES_CONFIG = "fetch.min.bytes"
focal_class.modifier: public static final
focal_class.original_string: public static final String FETCH_MIN_BYTES_CONFIG = "fetch.min.bytes";
focal_class.type: String
focal_class.var_name: FETCH_MIN_BYTES_CONFIG
focal_class.declarator: FETCH_MIN_BYTES_DOC = "The minimum amount of data the server should return for a fetch request. If insufficient data is available the request will wait for that much data to accumulate before answering the request. The default setting of 1 byte means that fetch requests are answered as soon as a single byte of data is available or the fetch request times out waiting for data to arrive. Setting this to something greater than 1 will cause the server to wait for larger amounts of data to accumulate which can improve server throughput a bit at the cost of some additional latency."
focal_class.modifier: private static final
focal_class.original_string: private static final String FETCH_MIN_BYTES_DOC = "The minimum amount of data the server should return for a fetch request. If insufficient data is available the request will wait for that much data to accumulate before answering the request. The default setting of 1 byte means that fetch requests are answered as soon as a single byte of data is available or the fetch request times out waiting for data to arrive. Setting this to something greater than 1 will cause the server to wait for larger amounts of data to accumulate which can improve server throughput a bit at the cost of some additional latency.";
focal_class.type: String
focal_class.var_name: FETCH_MIN_BYTES_DOC
focal_class.declarator: FETCH_MAX_WAIT_MS_CONFIG = "fetch.max.wait.ms"
focal_class.modifier: public static final
focal_class.original_string: public static final String FETCH_MAX_WAIT_MS_CONFIG = "fetch.max.wait.ms";
focal_class.type: String
focal_class.var_name: FETCH_MAX_WAIT_MS_CONFIG
focal_class.declarator: FETCH_MAX_WAIT_MS_DOC = "The maximum amount of time the server will block before answering the fetch request if there isn't sufficient data to immediately satisfy the requirement given by fetch.min.bytes."
focal_class.modifier: private static final
focal_class.original_string: private static final String FETCH_MAX_WAIT_MS_DOC = "The maximum amount of time the server will block before answering the fetch request if there isn't sufficient data to immediately satisfy the requirement given by fetch.min.bytes.";
focal_class.type: String
focal_class.var_name: FETCH_MAX_WAIT_MS_DOC
focal_class.declarator: METADATA_MAX_AGE_CONFIG = CommonClientConfigs.METADATA_MAX_AGE_CONFIG
focal_class.modifier: public static final
focal_class.original_string: public static final String METADATA_MAX_AGE_CONFIG = CommonClientConfigs.METADATA_MAX_AGE_CONFIG;
focal_class.type: String
focal_class.var_name: METADATA_MAX_AGE_CONFIG
focal_class.declarator: MAX_PARTITION_FETCH_BYTES_CONFIG = "max.partition.fetch.bytes"
focal_class.modifier: public static final
focal_class.original_string: public static final String MAX_PARTITION_FETCH_BYTES_CONFIG = "max.partition.fetch.bytes";
focal_class.type: String
focal_class.var_name: MAX_PARTITION_FETCH_BYTES_CONFIG
focal_class.declarator: MAX_PARTITION_FETCH_BYTES_DOC = "The maximum amount of data per-partition the server will return. The maximum total memory used for a request will be <code>#partitions * max.partition.fetch.bytes</code>. This size must be at least as large as the maximum message size the server allows or else it is possible for the producer to send messages larger than the consumer can fetch. If that happens, the consumer can get stuck trying to fetch a large message on a certain partition."
focal_class.modifier: private static final
focal_class.original_string: private static final String MAX_PARTITION_FETCH_BYTES_DOC = "The maximum amount of data per-partition the server will return. The maximum total memory used for a request will be <code>#partitions * max.partition.fetch.bytes</code>. This size must be at least as large as the maximum message size the server allows or else it is possible for the producer to send messages larger than the consumer can fetch. If that happens, the consumer can get stuck trying to fetch a large message on a certain partition.";
focal_class.type: String
focal_class.var_name: MAX_PARTITION_FETCH_BYTES_DOC
focal_class.declarator: DEFAULT_MAX_PARTITION_FETCH_BYTES = 1 * 1024 * 1024
focal_class.modifier: public static final
focal_class.original_string: public static final int DEFAULT_MAX_PARTITION_FETCH_BYTES = 1 * 1024 * 1024;
focal_class.type: int
focal_class.var_name: DEFAULT_MAX_PARTITION_FETCH_BYTES
focal_class.declarator: SEND_BUFFER_CONFIG = CommonClientConfigs.SEND_BUFFER_CONFIG
focal_class.modifier: public static final
focal_class.original_string: public static final String SEND_BUFFER_CONFIG = CommonClientConfigs.SEND_BUFFER_CONFIG;
focal_class.type: String
focal_class.var_name: SEND_BUFFER_CONFIG
focal_class.declarator: RECEIVE_BUFFER_CONFIG = CommonClientConfigs.RECEIVE_BUFFER_CONFIG
focal_class.modifier: public static final
focal_class.original_string: public static final String RECEIVE_BUFFER_CONFIG = CommonClientConfigs.RECEIVE_BUFFER_CONFIG;
focal_class.type: String
focal_class.var_name: RECEIVE_BUFFER_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.declarator: RECONNECT_BACKOFF_MS_CONFIG = CommonClientConfigs.RECONNECT_BACKOFF_MS_CONFIG
focal_class.modifier: public static final
focal_class.original_string: public static final String RECONNECT_BACKOFF_MS_CONFIG = CommonClientConfigs.RECONNECT_BACKOFF_MS_CONFIG;
focal_class.type: String
focal_class.var_name: RECONNECT_BACKOFF_MS_CONFIG
focal_class.declarator: RETRY_BACKOFF_MS_CONFIG = CommonClientConfigs.RETRY_BACKOFF_MS_CONFIG
focal_class.modifier: public static final
focal_class.original_string: public static final String RETRY_BACKOFF_MS_CONFIG = CommonClientConfigs.RETRY_BACKOFF_MS_CONFIG;
focal_class.type: String
focal_class.var_name: RETRY_BACKOFF_MS_CONFIG
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: CHECK_CRCS_CONFIG = "check.crcs"
focal_class.modifier: public static final
focal_class.original_string: public static final String CHECK_CRCS_CONFIG = "check.crcs";
focal_class.type: String
focal_class.var_name: CHECK_CRCS_CONFIG
focal_class.declarator: CHECK_CRCS_DOC = "Automatically check the CRC32 of the records consumed. This ensures no on-the-wire or on-disk corruption to the messages occurred. This check adds some overhead, so it may be disabled in cases seeking extreme performance."
focal_class.modifier: private static final
focal_class.original_string: private static final String CHECK_CRCS_DOC = "Automatically check the CRC32 of the records consumed. This ensures no on-the-wire or on-disk corruption to the messages occurred. This check adds some overhead, so it may be disabled in cases seeking extreme performance.";
focal_class.type: String
focal_class.var_name: CHECK_CRCS_DOC
focal_class.declarator: KEY_DESERIALIZER_CLASS_CONFIG = "key.deserializer"
focal_class.modifier: public static final
focal_class.original_string: public static final String KEY_DESERIALIZER_CLASS_CONFIG = "key.deserializer";
focal_class.type: String
focal_class.var_name: KEY_DESERIALIZER_CLASS_CONFIG
focal_class.declarator: KEY_DESERIALIZER_CLASS_DOC = "Deserializer class for key that implements the <code>Deserializer</code> interface."
focal_class.modifier: public static final
focal_class.original_string: public static final String KEY_DESERIALIZER_CLASS_DOC = "Deserializer class for key that implements the <code>Deserializer</code> interface.";
focal_class.type: String
focal_class.var_name: KEY_DESERIALIZER_CLASS_DOC
focal_class.declarator: VALUE_DESERIALIZER_CLASS_CONFIG = "value.deserializer"
focal_class.modifier: public static final
focal_class.original_string: public static final String VALUE_DESERIALIZER_CLASS_CONFIG = "value.deserializer";
focal_class.type: String
focal_class.var_name: VALUE_DESERIALIZER_CLASS_CONFIG
focal_class.declarator: VALUE_DESERIALIZER_CLASS_DOC = "Deserializer class for value that implements the <code>Deserializer</code> interface."
focal_class.modifier: public static final
focal_class.original_string: public static final String VALUE_DESERIALIZER_CLASS_DOC = "Deserializer class for value that implements the <code>Deserializer</code> interface.";
focal_class.type: String
focal_class.var_name: VALUE_DESERIALIZER_CLASS_DOC
focal_class.declarator: CONNECTIONS_MAX_IDLE_MS_CONFIG = CommonClientConfigs.CONNECTIONS_MAX_IDLE_MS_CONFIG
focal_class.modifier: public static final
focal_class.original_string: public static final String CONNECTIONS_MAX_IDLE_MS_CONFIG = CommonClientConfigs.CONNECTIONS_MAX_IDLE_MS_CONFIG;
focal_class.type: String
focal_class.var_name: CONNECTIONS_MAX_IDLE_MS_CONFIG
focal_class.declarator: REQUEST_TIMEOUT_MS_CONFIG = CommonClientConfigs.REQUEST_TIMEOUT_MS_CONFIG
focal_class.modifier: public static final
focal_class.original_string: public static final String REQUEST_TIMEOUT_MS_CONFIG = CommonClientConfigs.REQUEST_TIMEOUT_MS_CONFIG;
focal_class.type: String
focal_class.var_name: REQUEST_TIMEOUT_MS_CONFIG
focal_class.declarator: REQUEST_TIMEOUT_MS_DOC = CommonClientConfigs.REQUEST_TIMEOUT_MS_DOC
focal_class.modifier: private static final
focal_class.original_string: private static final String REQUEST_TIMEOUT_MS_DOC = CommonClientConfigs.REQUEST_TIMEOUT_MS_DOC;
focal_class.type: String
focal_class.var_name: REQUEST_TIMEOUT_MS_DOC
focal_class.declarator: INTERCEPTOR_CLASSES_CONFIG = "interceptor.classes"
focal_class.modifier: public static final
focal_class.original_string: public static final String INTERCEPTOR_CLASSES_CONFIG = "interceptor.classes";
focal_class.type: String
focal_class.var_name: INTERCEPTOR_CLASSES_CONFIG
focal_class.declarator: INTERCEPTOR_CLASSES_DOC = "A list of classes to use as interceptors. "
                                                          + "Implementing the <code>ConsumerInterceptor</code> interface allows you to intercept (and possibly mutate) records "
                                                          + "received by the consumer. By default, there are no interceptors."
focal_class.modifier: public static final
focal_class.original_string: public static final String INTERCEPTOR_CLASSES_DOC = "A list of classes to use as interceptors. "
                                                          + "Implementing the <code>ConsumerInterceptor</code> interface allows you to intercept (and possibly mutate) records "
                                                          + "received by the consumer. By default, there are no interceptors.";
focal_class.type: String
focal_class.var_name: INTERCEPTOR_CLASSES_DOC
focal_class.declarator: EXCLUDE_INTERNAL_TOPICS_CONFIG = "exclude.internal.topics"
focal_class.modifier: public static final
focal_class.original_string: public static final String EXCLUDE_INTERNAL_TOPICS_CONFIG = "exclude.internal.topics";
focal_class.type: String
focal_class.var_name: EXCLUDE_INTERNAL_TOPICS_CONFIG
focal_class.declarator: EXCLUDE_INTERNAL_TOPICS_DOC = "Whether records from internal topics (such as offsets) should be exposed to the consumer. "
                                                              + "If set to <code>true</code> the only way to receive records from an internal topic is subscribing to it."
focal_class.modifier: private static final
focal_class.original_string: private static final String EXCLUDE_INTERNAL_TOPICS_DOC = "Whether records from internal topics (such as offsets) should be exposed to the consumer. "
                                                              + "If set to <code>true</code> the only way to receive records from an internal topic is subscribing to it.";
focal_class.type: String
focal_class.var_name: EXCLUDE_INTERNAL_TOPICS_DOC
focal_class.declarator: DEFAULT_EXCLUDE_INTERNAL_TOPICS = true
focal_class.modifier: public static final
focal_class.original_string: public static final boolean DEFAULT_EXCLUDE_INTERNAL_TOPICS = true;
focal_class.type: boolean
focal_class.var_name: DEFAULT_EXCLUDE_INTERNAL_TOPICS
focal_class.file: clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerConfig.java
focal_class.identifier: ConsumerConfig
focal_class.class_method_signature: ConsumerConfig.addDeserializerToConfig(Map<String, Object> configs,
                                                                Deserializer<?> keyDeserializer,
                                                                Deserializer<?> valueDeserializer)
focal_class.full_signature: public static Map<String, Object> addDeserializerToConfig(Map<String, Object> configs,
                                                                Deserializer<?> keyDeserializer,
                                                                Deserializer<?> valueDeserializer)
focal_class.identifier: addDeserializerToConfig
focal_class.modifiers: public static
focal_class.parameters: (Map<String, Object> configs,
                                                                Deserializer<?> keyDeserializer,
                                                                Deserializer<?> valueDeserializer)
focal_class.return: Map<String, Object>
focal_class.signature: Map<String, Object> addDeserializerToConfig(Map<String, Object> configs,
                                                                Deserializer<?> keyDeserializer,
                                                                Deserializer<?> valueDeserializer)
focal_class.class_method_signature: ConsumerConfig.addDeserializerToConfig(Properties properties,
                                                       Deserializer<?> keyDeserializer,
                                                       Deserializer<?> valueDeserializer)
focal_class.full_signature: public static Properties addDeserializerToConfig(Properties properties,
                                                       Deserializer<?> keyDeserializer,
                                                       Deserializer<?> valueDeserializer)
focal_class.identifier: addDeserializerToConfig
focal_class.modifiers: public static
focal_class.parameters: (Properties properties,
                                                       Deserializer<?> keyDeserializer,
                                                       Deserializer<?> valueDeserializer)
focal_class.return: Properties
focal_class.signature: Properties addDeserializerToConfig(Properties properties,
                                                       Deserializer<?> keyDeserializer,
                                                       Deserializer<?> valueDeserializer)
focal_class.class_method_signature: ConsumerConfig.ConsumerConfig(Map<?, ?> props)
focal_class.full_signature:   ConsumerConfig(Map<?, ?> props)
focal_class.identifier: ConsumerConfig
focal_class.parameters: (Map<?, ?> props)
focal_class.signature:  ConsumerConfig(Map<?, ?> props)
focal_class.class_method_signature: ConsumerConfig.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 static Map<String, Object> addDeserializerToConfig(Map<String, Object> configs,
                                                                Deserializer<?> keyDeserializer,
                                                                Deserializer<?> valueDeserializer) {
          Map<String, Object> newConfigs = new HashMap<String, Object>();
          newConfigs.putAll(configs);
          if (keyDeserializer != null)
              newConfigs.put(KEY_DESERIALIZER_CLASS_CONFIG, keyDeserializer.getClass());
          if (valueDeserializer != null)
              newConfigs.put(VALUE_DESERIALIZER_CLASS_CONFIG, valueDeserializer.getClass());
          return newConfigs;
      }
focal_method.class_method_signature: ConsumerConfig.addDeserializerToConfig(Map<String, Object> configs,
                                                                Deserializer<?> keyDeserializer,
                                                                Deserializer<?> valueDeserializer)
focal_method.full_signature: public static Map<String, Object> addDeserializerToConfig(Map<String, Object> configs,
                                                                Deserializer<?> keyDeserializer,
                                                                Deserializer<?> valueDeserializer)
focal_method.identifier: addDeserializerToConfig
focal_method.invocations: putAll put getClass put getClass
focal_method.modifiers: public static
focal_method.parameters: (Map<String, Object> configs,
                                                                Deserializer<?> keyDeserializer,
                                                                Deserializer<?> valueDeserializer)
focal_method.return: Map<String, Object>
focal_method.signature: Map<String, Object> addDeserializerToConfig(Map<String, Object> configs,
                                                                Deserializer<?> keyDeserializer,
                                                                Deserializer<?> valueDeserializer)