diff --git a/streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java b/streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java index 90c620b707a44..33244c5870f3d 100644 --- a/streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java +++ b/streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java @@ -1180,23 +1180,6 @@ private void verifyMaxInFlightRequestPerConnection(final Object maxInFlightReque } } - /** - * Get the configs to the {@link KafkaConsumer consumer}. - * Properties using the prefix {@link #CONSUMER_PREFIX} will be used in favor over their non-prefixed versions - * except in the case of {@link ConsumerConfig#BOOTSTRAP_SERVERS_CONFIG} where we always use the non-prefixed - * version as we only support reading/writing from/to the same Kafka Cluster. - * - * @param groupId consumer groupId - * @param clientId clientId - * @return Map of the consumer configuration. - * @deprecated use {@link StreamsConfig#getMainConsumerConfigs(String, String, int)} - */ - @SuppressWarnings("WeakerAccess") - @Deprecated - public Map getConsumerConfigs(final String groupId, final String clientId) { - return getMainConsumerConfigs(groupId, clientId, DUMMY_THREAD_INDEX); - } - /** * Get the configs to the {@link KafkaConsumer main consumer}. * Properties using the prefix {@link #MAIN_CONSUMER_PREFIX} will be used in favor over