getting the following error message.

ksql> CREATE STREAM CUSTOMERS_SRC WITH (KAFKA_TOPIC='asgard.public.customers', VALUE_FORMAT='AVRO'); Avro schema for message values on topic asgard.public.customers does not exist in the

Seems like the published docs https://www.2ndquadrant.com/en/resources/pglogical/pglogical-docs/

are not up to date with the info in the readme https://github.com/2ndQuadrant/pglogical

This wasted a lot of time for me because of a couple pieces of missing info. Might be good to merge them, or take one down.

Thanks for a great project!

Description

在全量迁移时 create table 阶段会执行 count操作，表创建完了，开始迁移数据时还会count。 所以create table阶段的 count操作可否省略掉。

Steps to reproduce the issue:
1.
2.
3.

Describe the results you received:

Describe the results you expected:

Output of ./dtle version:

(paste your output here)

**Additional information you deem important (e.g. issue happens only occasionally

Having stdout output and configuration through command line options will allow to use Storagetapper as a command line utility.

• kafka.acks and kafka.transaction.id need to be explained more. Many deployments don't seem to need them by default and they can be confusing. Is this for reading your own writes? Only applies when producing and consuming in the same system.
• neo4j.batch.size is documented, but is confusingly similar and overlaps with kafka.batch.size. Clarify and probably remove neo4j.batch.size because i

-Dpact.rootDir="target/pact-classes" didn’t work for me.
env "pact.rootDir=target/pact-classes" bash did

...because of the "."

Since input record offsets are stored in RocksDB, it can be difficult to debug issues which require knowing the input topic offset that corresponds to the last message consumed. This information is necessary to obtain the message that, for example, caused a crash. Some documentation on how this should be done would be very helpful.