public static StreamClient get(Context context) {
        Config streamConfig = ConfigUtils.to(context.kafkaConfig);
        ObjectStorage objectStorage = ObjectStorageFactory.instance().builder()
            .buckets(streamConfig.dataBuckets())
            .tagging(streamConfig.objectTagging())
            .extension(EXTENSION_TYPE_KEY, EXTENSION_TYPE_BACKGROUND)
            .build();
        return StreamClient.builder()
            .streamConfig(streamConfig)
            .objectStorage(objectStorage)
            .build();
    }
This method will be called by {@link StreamClientFactoryProxy}
core/src/main/scala/kafka/controller/streamaspect/client/s3/StreamClientFactory.java