我正在開發一個連接到邏輯複製插槽的應用程序，以消耗WAL事件。這些WAL事件然後被轉發給MQ代理。這很有效，但我注意到一段時間後我的內存不足了。我設法將問題最小化爲負責獲取WAL事件的代碼。它發生用下面的代碼： final Properties properties = new Properties();
PGProperty.USER.set(properties, "user");
PG
已啓用MySql ROW級別binloging。 ERROR Failed to start the connector (see other exception), but got this error while cleaning up (io.debezium.connector.mysql.MySqlConnectorTask:183)
java.lang.NullPointerExce
Debezium連接器的Kafka連接事件是Avro編碼。 在傳遞給Kafka連接獨立服務的connect-standalone.properties中提到了以下內容。 key.converter=io.confluent.connect.avro.AvroConverter
value.confluent=io.confluent.connect.avro.AvroConverter
int