Skip to content

Commit

Permalink
KAFKA-16223 Replace EasyMock/PowerMock with Mockito for KafkaConfigBa…
Browse files Browse the repository at this point in the history
…ckingStoreTest (1/3) (#15520)

Reviewers: Greg Harris <[email protected]>
  • Loading branch information
hgeraldino authored Mar 29, 2024
1 parent 7317159 commit 2118d85
Show file tree
Hide file tree
Showing 3 changed files with 509 additions and 266 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -293,7 +293,7 @@ public static String LOGGER_CLUSTER_KEY(String namespace) {
private final String topic;
// Data is passed to the log already serialized. We use a converter to handle translating to/from generic Connect
// format to serialized form
private final KafkaBasedLog<String, byte[]> configLog;
private KafkaBasedLog<String, byte[]> configLog;
// Connector -> # of tasks
final Map<String, Integer> connectorTaskCounts = new HashMap<>();
// Connector and task configs: name or id -> config map
Expand Down Expand Up @@ -329,6 +329,11 @@ public static String LOGGER_CLUSTER_KEY(String namespace) {
private final Map<String, Object> fencableProducerProps;
private final Time time;

//VisibleForTesting
void setConfigLog(KafkaBasedLog<String, byte[]> configLog) {
this.configLog = configLog;
}

@Deprecated
public KafkaConfigBackingStore(Converter converter, DistributedConfig config, WorkerConfigTransformer configTransformer) {
this(converter, config, configTransformer, null, "connect-distributed-");
Expand Down
Loading

0 comments on commit 2118d85

Please sign in to comment.