diff --git a/cli/command_benchmark_compression.go b/cli/command_benchmark_compression.go
new file mode 100644
index 000000000..7d5303c99
--- /dev/null
+++ b/cli/command_benchmark_compression.go
@@ -0,0 +1,110 @@
+package cli
+
+import (
+	"hash/fnv"
+	"io/ioutil"
+	"sort"
+	"time"
+
+	"github.com/kopia/kopia/internal/units"
+	"github.com/kopia/kopia/repo/object"
+
+	kingpin "gopkg.in/alecthomas/kingpin.v2"
+)
+
+var (
+	benchmarkCompressionCommand      = benchmarkCommands.Command("compression", "Run compression benchmarks")
+	benchmarkCompressionBlockSize    = benchmarkCompressionCommand.Flag("block-size", "Size of a block to encrypt").Default("1MB").Bytes()
+	benchmarkCompressionRepeat       = benchmarkCompressionCommand.Flag("repeat", "Number of repetitions").Default("100").Int()
+	benchmarkCompressionDataFile     = benchmarkCompressionCommand.Flag("data-file", "Use data from the given file instead of empty").ExistingFile()
+	benchmarkCompressionBySize       = benchmarkCompressionCommand.Flag("by-size", "Sort results by size").Bool()
+	benchmarkCompressionVerifyStable = benchmarkCompressionCommand.Flag("verify-stable", "Verify that compression is stable").Bool()
+)
+
+func runBenchmarkCompressionAction(ctx *kingpin.ParseContext) error {
+	type benchResult struct {
+		compression    object.CompressorName
+		throughput     float64
+		compressedSize int64
+	}
+
+	var results []benchResult
+
+	data := make([]byte, *benchmarkCompressionBlockSize)
+
+	if *benchmarkCompressionDataFile != "" {
+		d, err := ioutil.ReadFile(*benchmarkCompressionDataFile)
+		if err != nil {
+			return err
+		}
+
+		data = d
+	}
+
+	for name, comp := range object.CompressorsByName {
+		log.Infof("Benchmarking compressor '%v' (%v x %v bytes)", name, *benchmarkCompressionRepeat, len(data))
+
+		t0 := time.Now()
+
+		var compressedSize int64
+
+		var lastHash uint64
+
+		cnt := *benchmarkCompressionRepeat
+		for i := 0; i < cnt; i++ {
+			compressed, err := comp.Compress(data)
+			if err != nil {
+				log.Warningf("compression failed: %v", err)
+				continue
+			}
+
+			compressedSize = int64(len(compressed))
+
+			if *benchmarkCompressionVerifyStable {
+				h := hashOf(compressed)
+
+				if i == 0 {
+					lastHash = h
+				} else if h != lastHash {
+					log.Warningf("compression is not stable")
+					continue
+				}
+			}
+		}
+
+		hashTime := time.Since(t0)
+		bytesPerSecond := float64(len(data)) * float64(cnt) / hashTime.Seconds()
+
+		results = append(results, benchResult{compression: name, throughput: bytesPerSecond, compressedSize: compressedSize})
+	}
+
+	if *benchmarkCompressionBySize {
+		sort.Slice(results, func(i, j int) bool {
+			return results[i].compressedSize < results[j].compressedSize
+		})
+	} else {
+		sort.Slice(results, func(i, j int) bool {
+			return results[i].throughput > results[j].throughput
+		})
+	}
+
+	printStdout("     %-30v %-15v %v\n", "Compression", "Compressed Size", "Throughput")
+	printStdout("-----------------------------------------------------------------\n")
+
+	for ndx, r := range results {
+		printStdout("%3d. %-30v %-15v %v / second\n", ndx, r.compression, r.compressedSize, units.BytesStringBase2(int64(r.throughput)))
+	}
+
+	return nil
+}
+
+func init() {
+	benchmarkCompressionCommand.Action(runBenchmarkCompressionAction)
+}
+
+func hashOf(b []byte) uint64 {
+	h := fnv.New64a()
+	h.Write(b) // nolint:errcheck
+
+	return h.Sum64()
+}