diff --git a/data_diff/__main__.py b/data_diff/__main__.py
index d0d4ad4a..daaa6f65 100644
--- a/data_diff/__main__.py
+++ b/data_diff/__main__.py
@@ -1,129 +1,138 @@
-from multiprocessing.sharedctypes import Value
-import sys
-import time
-import logging
-from itertools import islice
-
-from .diff_tables import TableSegment, TableDiffer
-from .database import connect_to_uri
-from .parse_time import parse_time_before_now, UNITS_STR, ParseError
-
-import click
-
-LOG_FORMAT = "[%(asctime)s] %(levelname)s - %(message)s"
-DATE_FORMAT = "%H:%M:%S"
-
-
-@click.command()
-@click.argument("db1_uri")
-@click.argument("table1_name")
-@click.argument("db2_uri")
-@click.argument("table2_name")
-@click.option("-k", "--key-column", default="id", help="Name of primary key column")
-@click.option("-t", "--update-column", default=None, help="Name of updated_at/last_updated column")
-@click.option("-c", "--columns", default=[], multiple=True, help="Names of extra columns to compare")
-@click.option("-l", "--limit", default=None, help="Maximum number of differences to find")
-@click.option("--bisection-factor", default=32, help="Segments per iteration")
-@click.option("--bisection-threshold", default=1024**2, help="Minimal bisection threshold")
-@click.option(
-    "--min-age",
-    default=None,
-    help="Considers only rows older than specified. "
-    "Example: --min-age=5min ignores rows from the last 5 minutes. "
-    f"\nValid units: {UNITS_STR}",
-)
-@click.option("--max-age", default=None, help="Considers only rows younger than specified. See --min-age.")
-@click.option("-s", "--stats", is_flag=True, help="Print stats instead of a detailed diff")
-@click.option("-d", "--debug", is_flag=True, help="Print debug info")
-@click.option("-v", "--verbose", is_flag=True, help="Print extra info")
-@click.option("-i", "--interactive", is_flag=True, help="Confirm queries, implies --debug")
-@click.option("-j", "--threads", default=None, help="Number of threads to use. 1 means no threading. Auto if not specified.")
-def main(
-    db1_uri,
-    table1_name,
-    db2_uri,
-    table2_name,
-    key_column,
-    update_column,
-    columns,
-    limit,
-    bisection_factor,
-    bisection_threshold,
-    min_age,
-    max_age,
-    stats,
-    debug,
-    verbose,
-    interactive,
-    threads,
-):
-    if limit and stats:
-        print("Error: cannot specify a limit when using the -s/--stats switch")
-        return
-    if interactive:
-        debug = True
-
-    if debug:
-        logging.basicConfig(level=logging.DEBUG, format=LOG_FORMAT, datefmt=DATE_FORMAT)
-    elif verbose:
-        logging.basicConfig(level=logging.INFO, format=LOG_FORMAT, datefmt=DATE_FORMAT)
-
-    if threads is not None:
-        threads = int(threads)
-        if threads < 1:
-            logging.error("Error: threads must be >= 1")
-            return
-
-    db1 = connect_to_uri(db1_uri, threads)
-    db2 = connect_to_uri(db2_uri, threads)
-
-    if interactive:
-        db1.enable_interactive()
-        db2.enable_interactive()
-
-    start = time.time()
-
-    try:
-        options = dict(
-            min_time=min_age and parse_time_before_now(min_age), max_time=max_age and parse_time_before_now(max_age)
-        )
-    except ParseError as e:
-        logging.error("Error while parsing age expression: %s" % e)
-        return
-
-    table1 = TableSegment(db1, (table1_name,), key_column, update_column, columns, **options)
-    table2 = TableSegment(db2, (table2_name,), key_column, update_column, columns, **options)
-
-    differ = TableDiffer(
-        bisection_factor=bisection_factor,
-        bisection_threshold=bisection_threshold,
-        debug=debug,
-        threaded=threads != 1,
-        max_threadpool_size=threads,
-    )
-    diff_iter = differ.diff_tables(table1, table2)
-
-    if limit:
-        diff_iter = islice(diff_iter, int(limit))
-
-    if stats:
-        diff = list(diff_iter)
+from multiprocessing.sharedctypes import Value
+import sys
+import time
+import logging
+from itertools import islice
+
+from .diff_tables import TableSegment, TableDiffer
+from .database import connect_to_uri
+from .parse_time import parse_time_before_now, UNITS_STR, ParseError
+
+import rich
+import click
+
+LOG_FORMAT = "[%(asctime)s] %(levelname)s - %(message)s"
+DATE_FORMAT = "%H:%M:%S"
+
+COLOR_SCHEME = {
+    "+": "green",
+    "-": "red",
+}
+
+
+@click.command()
+@click.argument("db1_uri")
+@click.argument("table1_name")
+@click.argument("db2_uri")
+@click.argument("table2_name")
+@click.option("-k", "--key-column", default="id", help="Name of primary key column")
+@click.option("-t", "--update-column", default=None, help="Name of updated_at/last_updated column")
+@click.option("-c", "--columns", default=[], multiple=True, help="Names of extra columns to compare")
+@click.option("-l", "--limit", default=None, help="Maximum number of differences to find")
+@click.option("--bisection-factor", default=32, help="Segments per iteration")
+@click.option("--bisection-threshold", default=1024**2, help="Minimal bisection threshold")
+@click.option(
+    "--min-age",
+    default=None,
+    help="Considers only rows older than specified. "
+    "Example: --min-age=5min ignores rows from the last 5 minutes. "
+    f"\nValid units: {UNITS_STR}",
+)
+@click.option("--max-age", default=None, help="Considers only rows younger than specified. See --min-age.")
+@click.option("-s", "--stats", is_flag=True, help="Print stats instead of a detailed diff")
+@click.option("-d", "--debug", is_flag=True, help="Print debug info")
+@click.option("-v", "--verbose", is_flag=True, help="Print extra info")
+@click.option("-i", "--interactive", is_flag=True, help="Confirm queries, implies --debug")
+@click.option(
+    "-j", "--threads", default=None, help="Number of threads to use. 1 means no threading. Auto if not specified."
+)
+def main(
+    db1_uri,
+    table1_name,
+    db2_uri,
+    table2_name,
+    key_column,
+    update_column,
+    columns,
+    limit,
+    bisection_factor,
+    bisection_threshold,
+    min_age,
+    max_age,
+    stats,
+    debug,
+    verbose,
+    interactive,
+    threads,
+):
+    if limit and stats:
+        print("Error: cannot specify a limit when using the -s/--stats switch")
+        return
+    if interactive:
+        debug = True
+
+    if debug:
+        logging.basicConfig(level=logging.DEBUG, format=LOG_FORMAT, datefmt=DATE_FORMAT)
+    elif verbose:
+        logging.basicConfig(level=logging.INFO, format=LOG_FORMAT, datefmt=DATE_FORMAT)
+
+    if threads is not None:
+        threads = int(threads)
+        if threads < 1:
+            logging.error("Error: threads must be >= 1")
+            return
+
+    db1 = connect_to_uri(db1_uri, threads)
+    db2 = connect_to_uri(db2_uri, threads)
+
+    if interactive:
+        db1.enable_interactive()
+        db2.enable_interactive()
+
+    start = time.time()
+
+    try:
+        options = dict(
+            min_time=min_age and parse_time_before_now(min_age), max_time=max_age and parse_time_before_now(max_age)
+        )
+    except ParseError as e:
+        logging.error("Error while parsing age expression: %s" % e)
+        return
+
+    table1 = TableSegment(db1, (table1_name,), key_column, update_column, columns, **options)
+    table2 = TableSegment(db2, (table2_name,), key_column, update_column, columns, **options)
+
+    differ = TableDiffer(
+        bisection_factor=bisection_factor,
+        bisection_threshold=bisection_threshold,
+        debug=debug,
+        threaded=threads != 1,
+        max_threadpool_size=threads,
+    )
+    diff_iter = differ.diff_tables(table1, table2)
+
+    if limit:
+        diff_iter = islice(diff_iter, int(limit))
+
+    if stats:
+        diff = list(diff_iter)
         unique_diff_count = len({i[0] for _, i in diff})
         percent = 100 * unique_diff_count / table1.count
-        print(f"Diff-Total: {len(diff)} changed rows out of {table1.count}")
-        print(f"Diff-Percent: {percent:.4f}%")
-        plus = len([1 for op, _ in diff if op == "+"])
-        minus = len([1 for op, _ in diff if op == "-"])
-        print(f"Diff-Split: +{plus}  -{minus}")
-    else:
-        for op, key in diff_iter:
-            print(op, key)
-            sys.stdout.flush()
-
-    end = time.time()
-
-    logging.info(f"Duration: {end-start:.2f} seconds.")
-
-
-if __name__ == "__main__":
-    main()
+        print(f"Diff-Total: {len(diff)} changed rows out of {table1.count}")
+        print(f"Diff-Percent: {percent:.4f}%")
+        plus = len([1 for op, _ in diff if op == "+"])
+        minus = len([1 for op, _ in diff if op == "-"])
+        print(f"Diff-Split: +{plus}  -{minus}")
+    else:
+        for op, key in diff_iter:
+            color = COLOR_SCHEME[op]
+            rich.print(f"[{color}]{op} {key!r}[/{color}]")
+            sys.stdout.flush()
+
+    end = time.time()
+
+    logging.info(f"Duration: {end-start:.2f} seconds.")
+
+
+if __name__ == "__main__":
+    main()
diff --git a/pyproject.toml b/pyproject.toml
index 0c82dbe2..372f8932 100755
--- a/pyproject.toml
+++ b/pyproject.toml
@@ -27,6 +27,8 @@ python = "^3.7"
 runtype = "^0.2.4"
 dsnparse = "*"
 click = "^8.1"
+rich = "^10.16.2"
+
 
 preql = { version = "^0.2.13", optional = true }
 psycopg2 = { version = "*", optional = true }