SELECT SERVER_NAME,
CONNECT_USER,
CAPTURE_USER,
CAPTURE_NAME,
SOURCE_DATABASE,
QUEUE_OWNER,
QUEUE_NAME,
STATUS
FROM DBA_XSTREAM_OUTBOUND;
Outbound Capture
Server Connect Capture Process Source Queue Queue
Name User User Name Database Owner Name Status
---------- ---------- ---------- ----------- ----------- ---------- ---------- --------
DBZXOUT CXSTRM XSTRMADMIN CAP$_DBZXOU DEVDB SYS Q$_DBZXOUT DETACHED
T_53 _54
curl http://confluent-cp-kafka-connect:8083/connectors/txn-connector/tasks/0/status
{"state":"RUNNING","id":0,"worker_id":"confluent-cp-kafka-connect-qwhqr:8083"}
{ "name": "txn-connector", "config": { "connector.class" : "io.debezium.connector.oracle.OracleConnector", "tasks.max" : "1", "database.server.name" : "server1", "database.hostname" : "192.168.12.21", "database.port" : "1521", "database.user" : "xstrm", "database.password" : "password", "database.dbname" : "ORACLE_SID", "database.pdb.name": "ORACLE_SID", "database.out.server.name" : "dbzxout", "database.history.kafka.bootstrap.servers" : "confluent-cp-kafka-headless:9092", "database.history.kafka.topic": "txn-history" }}
Hi Gunnar, Thanks for reply. Here is output from oracle sql.COLUMN CAPTURE_NAME HEADING 'Capture|Name' FORMAT A15
COLUMN CREATE_MESSAGE HEADING 'Last LCR|Create Time'
COLUMN ENQUEUE_MESSAGE HEADING 'Last|Enqueue Time'
SELECT CAPTURE_NAME,
TO_CHAR(CAPTURE_MESSAGE_CREATE_TIME, 'HH24:MI:SS MM/DD/YY') CREATE_MESSAGE,
TO_CHAR(ENQUEUE_MESSAGE_CREATE_TIME, 'HH24:MI:SS MM/DD/YY') ENQUEUE_MESSAGE
FROM V$STREAMS_CAPTURE;
no rows selectedSQL> COLUMN CAPTURE_NAME HEADING 'Capture Process' FORMAT A30COLUMN ATTRIBUTE_NAME HEADING 'Attribute Name' FORMAT A30SELECT CAPTURE_NAME, ATTRIBUTE_NAMEFROM DBA_CAPTURE_EXTRA_ATTRIBUTESWHERE INCLUDE = 'YES'ORDER BY CAPTURE_NAME;SQL> SQL> SQL> 2 3 4no rows selectedSQL> SELECT STATE FROM V$PROPAGATION_RECEIVER;no rows selectedSQL> SELECT TOTAL_MEMORY_ALLOCATED/CURRENT_SIZE FROM V$STREAMS_POOL_STATISTICS;TOTAL_MEMORY_ALLOCATED/CURRENT_SIZE-----------------------------------.008696179SQL> SELECT STATE FROM V$STREAMS_CAPTURE;no rows selectedSQL> SELECT APPLY_NAME SUBSCRIBER, QUEUE_NAME FROM DBA_APPLY UNIONSELECT PROPAGATION_NAME, SOURCE_QUEUE_NAMEFROM DBA_PROPAGATIONORDER BY QUEUE_NAME; 2 3 4SUBSCRIBER QUEUE_NAME------------------------------ ------------------------------DBZXOUT Q$_DBZXOUT_54DBA CAPTURE STATUSSQL> SELECT CAPTURE_NAME, RULE_SET_NAME, RULE_SET_OWNER,ERROR_MESSAGE, STATUS, CLIENT_STATUS,CLIENT_NAME FROM DBA_CAPTURE;CaptureName RULE_SET_NAME RULE_ ERROR_MESSAGE STATUS CLIENT_STATUS CLIENT_NAME--------------- --------------- ----- ---------------------------------------- ---------- --------------- ---------------CAP$_DBZXOUT_53 RULESET$_61 SYS ENABLED DETACHED DBZXOUT
DETACHED - For XStream Out if the outbound server is running, but the XStream client application is not attached to it; For GoldenGate if the capture process is running, but the extract process is not attached to it--
You received this message because you are subscribed to the Google Groups "debezium" group.
To unsubscribe from this group and stop receiving emails from it, send an email to debezium+u...@googlegroups.com.
To view this discussion on the web visit https://groups.google.com/d/msgid/debezium/54144238-33f1-4dd8-a645-550174e87d47%40googlegroups.com.