Skip to content

Commit

Permalink
fix checkstyle stuff
Browse files Browse the repository at this point in the history
  • Loading branch information
agavra committed Nov 27, 2023
1 parent fc40821 commit ba9f85a
Show file tree
Hide file tree
Showing 5 changed files with 8 additions and 7 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -74,7 +74,7 @@ public ResponsiveKafkaClientSupplier(
final ResponsiveStoreRegistry storeRegistry,
final ResponsiveMetrics metrics,
final CompatibilityMode compatibilityMode
) {
) {
this(new Factories() {}, clientSupplier, configs, storeRegistry, metrics, compatibilityMode);
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -66,7 +66,7 @@ public EndOffsetsPoller(
final Map<String, ?> configs,
final ResponsiveMetrics metrics,
final KafkaClientSupplier clientSupplier
) {
) {
this(
configs,
metrics,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@

package dev.responsive.kafka.api;

import static dev.responsive.kafka.api.config.ResponsiveConfig.COMPATIBILITY_MODE_CONFIG;
import static dev.responsive.kafka.api.config.ResponsiveConfig.TENANT_ID_CONFIG;
import static org.apache.kafka.clients.consumer.ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG;
import static org.apache.kafka.clients.consumer.ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG;
Expand All @@ -31,7 +32,6 @@
import static org.mockito.Mockito.when;

import com.datastax.oss.driver.api.core.CqlSession;
import com.typesafe.config.ConfigException;
import dev.responsive.kafka.api.config.CompatibilityMode;
import dev.responsive.kafka.api.config.ResponsiveConfig;
import dev.responsive.kafka.internal.db.CassandraClient;
Expand Down Expand Up @@ -151,7 +151,7 @@ public void shouldInvalidateBadConfigs() {
@Test
public void shouldCreateResponsiveKafkaStreamsInMetricsOnlyModeWithUnverifiedConfigs() {
// Given:
properties.put(ResponsiveConfig.COMPATIBILITY_MODE_CONFIG, CompatibilityMode.METRICS_ONLY.name());
properties.put(COMPATIBILITY_MODE_CONFIG, CompatibilityMode.METRICS_ONLY.name());
properties.put(NUM_STANDBY_REPLICAS_CONFIG, 2); // a config that would cause failure

// When:
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,6 @@

package dev.responsive.kafka.integration;

import static dev.responsive.kafka.api.config.ResponsiveConfig.COMPATIBILITY_MODE_CONFIG;
import static dev.responsive.kafka.api.config.ResponsiveConfig.STORE_FLUSH_RECORDS_TRIGGER_CONFIG;
import static dev.responsive.kafka.testutils.IntegrationTestUtils.createTopicsAndWait;
import static dev.responsive.kafka.testutils.IntegrationTestUtils.pipeInput;
Expand All @@ -37,7 +36,6 @@
import static org.hamcrest.Matchers.hasItems;

import dev.responsive.kafka.api.ResponsiveKafkaStreams;
import dev.responsive.kafka.api.config.CompatibilityMode;
import dev.responsive.kafka.api.config.StorageBackend;
import dev.responsive.kafka.api.stores.ResponsiveKeyValueParams;
import dev.responsive.kafka.api.stores.ResponsiveStores;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -265,7 +265,10 @@ public void shouldNotCreateGlobalOrRestoreConsumerInMetricsCompatibilityMode() {
}

@NotNull
private ResponsiveKafkaClientSupplier supplier(final Map<String, Object> configs, final CompatibilityMode compat) {
private ResponsiveKafkaClientSupplier supplier(
final Map<String, Object> configs,
final CompatibilityMode compat
) {
return new ResponsiveKafkaClientSupplier(
factories,
wrapped,
Expand Down

0 comments on commit ba9f85a

Please sign in to comment.