Hi Team, I'm new to Airbyte.
I'm trying to set up ...
# replication-troubleshootingk
kavi arasu
12/05/2022, 11:47 AMHi Team, I'm new to Airbyte.
I'm trying to set up the destination as RabbitMQ in Airbyte, RabbitMQ is running in my local in port number 31673, but I'm getting below error
"Could not create connection: IncompatibleProtocolError: The protocol returned by the server is not supported: ("StreamLostError: ('Transport indicated EOF',)",)"
and I tried with default port (5672), but I'm getting below error
"Could not create connection: AMQPConnectionError: (AMQPConnectorSocketConnectError: ConnectionRefusedError(111, 'Connection refused'),)"
Please find the screenshots below for your reference.
m
Marcos Marx (Airbyte)
12/05/2022, 6:01 PMDid you create a network in Docker to make RabbitMQ and Airbyte knows each other?
k
kavi arasu
12/06/2022, 4:49 AMNo I haven't create any network in Docker
kavi arasu
12/06/2022, 4:52 AMBTW, its connected for me, it was a port issue
kavi arasu
12/06/2022, 4:57 AMAfter the successful connection, I'm facing one more issue, when I sync the data for the first time its pulling the data from source (MYSQL) and push the data in to RabbitMQ. But I have updated some records in my source table and I'm doing Sync, but this time that updated records are not reflected in RabbitMQ messages
kavi arasu
12/06/2022, 5:00 AMI have attached the connection settings screenshot for your reference
m
Marcos Marx (Airbyte)
12/06/2022, 5:36 PMI think you’re using the wrong cursor field that’s the reason. Cursor field corresponds to the column with the datatime update info
k
kavi arasu
12/07/2022, 5:14 AMWe need select cursor field as Primary Key column? Please Correct me If I wrong...
m
Marcos Marx (Airbyte)
12/07/2022, 5:07 PMNo, you don’t use both as equal. Cursor field => the column with timestamp/date update of record. PK => unique identifier of your data.
k
kavi arasu
12/08/2022, 8:04 AMOkay Thanks @Marcos Marx (Airbyte). I'll try this
6 Views