Greg Eremeev

>What about pure psycopg2? is it working? Yea, it works fine. >As far as I can see from docs, PG server should be configured appropriately too. Yea, I know. I...

Oh, it seems that I can't execute simple queries with this factory The same error ``` In [1]: from psycopg2.extras import LogicalReplicationConnection In [2]: import psycopg2 In [3]: conn =...

But if I try to execute this simple code I'll catch the same exception Without connection_factory parameter this code works fine. I think there is a bug in aiopg. Am...

Actually, exception happened when invoked `_enable_hstore` from aiopg/connection.py. This function requests info about hstore, but for logical replication it's forbidden request. **Anyway, psycopg2 don't allow use consume_stream method in async...

@jettify can I help with documentation? Where should this info be in documentation?

I read psycopg2 docs more detail and found that for asynchronous code need to use `read_message` method instead of `consume_stream`. It means, that most likely will need to fix code...

@ept thanks for reply and recommendation about Debezium. I'm going to check Debezium too. I'm pity that you don't support this repository any more. I read your articles from confluent.io,...

> Doing so is not recommended by REST architecture. > So REST recommends POST request on /nameservers/{nameserver-pk}/domains/bulk-create @himanshu-singh1995 Can you provide a link to clarify that comment? Where did you...

Actually, I meant https://www.postgresql.org/docs/9.6/static/logicaldecoding.html

I need asynchronous driver to consume messages from PostgreSQL and put them to queue. Every message issues when was change. I think if there are a lot of changes then...