When looking at the replication PID in pg_stat_activity for a PostgreSQL connector, the application name is currently set to Debezium Streaming
. Is it possible to customize this to be RisingWave
or My RisingWave cluster number 3
for better identification purposes?
Rick Otten
Asked on Feb 28, 2024
Example:
public class PostgresConnection extends JdbcConnection {
public static final String CONNECTION_STREAMING = "Debezium Streaming";
public static final String CONNECTION_SLOT_INFO = "Debezium Slot Info";
public static final String CONNECTION_DROP_SLOT = "Debezium Drop Slot";
public static final String CONNECTION_VALIDATE_CONNECTION = "Debezium Validate Connection";
public static final String CONNECTION_HEARTBEAT = "Debezium Heartbeat";
public static final String CONNECTION_GENERAL = "Debezium General";