-----dc1-----
list topics:
__consumer_offsets
__consumer_timestamps
_confluent-command
_confluent-license
_confluent-telemetry-metrics
_confluent_balancer_api_state
_confluent_balancer_broker_samples
_confluent_balancer_partition_samples
_schemas
connect-configs-dc1
connect-offsets-dc1
connect-status-dc1
topic1
topic2
topic1:
{"userid":{"string":"User_7"},"dc":{"string":"dc1"}}
{"userid":{"string":"User_7"},"dc":{"string":"dc2"}}
{"userid":{"string":"User_9"},"dc":{"string":"dc2"}}
{"userid":{"string":"User_2"},"dc":{"string":"dc1"}}
{"userid":{"string":"User_5"},"dc":{"string":"dc2"}}
{"userid":{"string":"User_1"},"dc":{"string":"dc1"}}
{"userid":{"string":"User_3"},"dc":{"string":"dc2"}}
{"userid":{"string":"User_7"},"dc":{"string":"dc1"}}
{"userid":{"string":"User_1"},"dc":{"string":"dc2"}}
{"userid":{"string":"User_8"},"dc":{"string":"dc1"}}
Processed a total of 10 messages
topic2:
{"registertime":{"long":1513471082347},"userid":{"string":"User_2"},"regionid":{"string":"Region_7"},"gender":{"string":"OTHER"}}
{"registertime":{"long":1496006007512},"userid":{"string":"User_5"},"regionid":{"string":"Region_6"},"gender":{"string":"OTHER"}}
{"registertime":{"long":1494319368203},"userid":{"string":"User_7"},"regionid":{"string":"Region_2"},"gender":{"string":"FEMALE"}}
{"registertime":{"long":1493150028737},"userid":{"string":"User_1"},"regionid":{"string":"Region_5"},"gender":{"string":"FEMALE"}}
{"registertime":{"long":1517151907191},"userid":{"string":"User_5"},"regionid":{"string":"Region_3"},"gender":{"string":"OTHER"}}
{"registertime":{"long":1489672305692},"userid":{"string":"User_2"},"regionid":{"string":"Region_6"},"gender":{"string":"OTHER"}}
{"registertime":{"long":1511471447951},"userid":{"string":"User_2"},"regionid":{"string":"Region_5"},"gender":{"string":"MALE"}}
{"registertime":{"long":1488018372941},"userid":{"string":"User_7"},"regionid":{"string":"Region_2"},"gender":{"string":"OTHER"}}
{"registertime":{"long":1500952152251},"userid":{"string":"User_2"},"regionid":{"string":"Region_1"},"gender":{"string":"MALE"}}
{"registertime":{"long":1493556444692},"userid":{"string":"User_1"},"regionid":{"string":"Region_8"},"gender":{"string":"FEMALE"}}
Processed a total of 10 messages
_schemas:
null
null
null
{"subject":"topic1-value","version":1,"id":1,"schema":"{\"type\":\"record\",\"name\":\"KsqlDataSourceSchema\",\"namespace\":\"io.confluent.ksql.avro_schemas\",\"fields\":[{\"name\":\"userid\",\"type\":[\"null\",\"string\"],\"default\":null},{\"name\":\"dc\",\"type\":[\"null\",\"string\"],\"default\":null}]}","deleted":false}
{"subject":"topic2-value","version":1,"id":2,"schema":"{\"type\":\"record\",\"name\":\"KsqlDataSourceSchema\",\"namespace\":\"io.confluent.ksql.avro_schemas\",\"fields\":[{\"name\":\"registertime\",\"type\":[\"null\",\"long\"],\"default\":null},{\"name\":\"userid\",\"type\":[\"null\",\"string\"],\"default\":null},{\"name\":\"regionid\",\"type\":[\"null\",\"string\"],\"default\":null},{\"name\":\"gender\",\"type\":[\"null\",\"string\"],\"default\":null}]}","deleted":false}
{"subject":"topic2.replica-value","version":1,"id":2,"schema":"{\"type\":\"record\",\"name\":\"KsqlDataSourceSchema\",\"namespace\":\"io.confluent.ksql.avro_schemas\",\"fields\":[{\"name\":\"registertime\",\"type\":[\"null\",\"long\"],\"default\":null},{\"name\":\"userid\",\"type\":[\"null\",\"string\"],\"default\":null},{\"name\":\"regionid\",\"type\":[\"null\",\"string\"],\"default\":null},{\"name\":\"gender\",\"type\":[\"null\",\"string\"],\"default\":null}]}","deleted":false}
[2021-01-04 19:16:09,579] ERROR Error processing message, terminating consumer process: (kafka.tools.ConsoleConsumer$)
org.apache.kafka.common.errors.TimeoutException
Processed a total of 6 messages
provenance info (cluster, topic, timestamp):
2qHo2TsdTIaTjvkCyf3qdw,topic1,1609787778125
2qHo2TsdTIaTjvkCyf3qdw,topic1,1609787779123
2qHo2TsdTIaTjvkCyf3qdw,topic1,1609787780125
2qHo2TsdTIaTjvkCyf3qdw,topic1,1609787781246
2qHo2TsdTIaTjvkCyf3qdw,topic1,1609787782125
Processed a total of 10 messages
timestamp info (group: topic-partition):
replicator-dc1-to-dc2-topic2: topic2-0 1609787797164
replicator-dc1-to-dc2-topic1: topic1-0 1609787797117
Processed a total of 2 messages
cluster id:
ZagAAEfORQG-lxwq6OsV5Q
-----dc2-----
list topics:
__consumer_offsets
__consumer_timestamps
_confluent-command
_confluent-controlcenter-6-1-0-1-AlertHistoryStore-changelog
_confluent-controlcenter-6-1-0-1-AlertHistoryStore-repartition
_confluent-controlcenter-6-1-0-1-Group-ONE_MINUTE-changelog
_confluent-controlcenter-6-1-0-1-Group-ONE_MINUTE-repartition
_confluent-controlcenter-6-1-0-1-Group-THREE_HOURS-changelog
_confluent-controlcenter-6-1-0-1-Group-THREE_HOURS-repartition
_confluent-controlcenter-6-1-0-1-KSTREAM-OUTEROTHER-0000000106-store-changelog
_confluent-controlcenter-6-1-0-1-KSTREAM-OUTEROTHER-0000000106-store-repartition
_confluent-controlcenter-6-1-0-1-KSTREAM-OUTERTHIS-0000000105-store-changelog
_confluent-controlcenter-6-1-0-1-KSTREAM-OUTERTHIS-0000000105-store-repartition
_confluent-controlcenter-6-1-0-1-MetricsAggregateStore-changelog
_confluent-controlcenter-6-1-0-1-MetricsAggregateStore-repartition
_confluent-controlcenter-6-1-0-1-MonitoringMessageAggregatorWindows-ONE_MINUTE-changelog
_confluent-controlcenter-6-1-0-1-MonitoringMessageAggregatorWindows-ONE_MINUTE-repartition
_confluent-controlcenter-6-1-0-1-MonitoringMessageAggregatorWindows-THREE_HOURS-changelog
_confluent-controlcenter-6-1-0-1-MonitoringMessageAggregatorWindows-THREE_HOURS-repartition
_confluent-controlcenter-6-1-0-1-MonitoringStream-ONE_MINUTE-changelog
_confluent-controlcenter-6-1-0-1-MonitoringStream-ONE_MINUTE-repartition
_confluent-controlcenter-6-1-0-1-MonitoringStream-THREE_HOURS-changelog
_confluent-controlcenter-6-1-0-1-MonitoringStream-THREE_HOURS-repartition
_confluent-controlcenter-6-1-0-1-MonitoringTriggerStore-changelog
_confluent-controlcenter-6-1-0-1-MonitoringTriggerStore-repartition
_confluent-controlcenter-6-1-0-1-MonitoringVerifierStore-changelog
_confluent-controlcenter-6-1-0-1-MonitoringVerifierStore-repartition
_confluent-controlcenter-6-1-0-1-TriggerActionsStore-changelog
_confluent-controlcenter-6-1-0-1-TriggerActionsStore-repartition
_confluent-controlcenter-6-1-0-1-TriggerEventsStore-changelog
_confluent-controlcenter-6-1-0-1-TriggerEventsStore-repartition
_confluent-controlcenter-6-1-0-1-actual-group-consumption-rekey
_confluent-controlcenter-6-1-0-1-aggregate-topic-partition-store-changelog
_confluent-controlcenter-6-1-0-1-aggregate-topic-partition-store-repartition
_confluent-controlcenter-6-1-0-1-aggregatedTopicPartitionTableWindows-ONE_MINUTE-changelog
_confluent-controlcenter-6-1-0-1-aggregatedTopicPartitionTableWindows-ONE_MINUTE-repartition
_confluent-controlcenter-6-1-0-1-aggregatedTopicPartitionTableWindows-THREE_HOURS-changelog
_confluent-controlcenter-6-1-0-1-aggregatedTopicPartitionTableWindows-THREE_HOURS-repartition
_confluent-controlcenter-6-1-0-1-cluster-rekey
_confluent-controlcenter-6-1-0-1-expected-group-consumption-rekey
_confluent-controlcenter-6-1-0-1-group-aggregate-store-ONE_MINUTE-changelog
_confluent-controlcenter-6-1-0-1-group-aggregate-store-ONE_MINUTE-repartition
_confluent-controlcenter-6-1-0-1-group-aggregate-store-THREE_HOURS-changelog
_confluent-controlcenter-6-1-0-1-group-aggregate-store-THREE_HOURS-repartition
_confluent-controlcenter-6-1-0-1-group-stream-extension-rekey
_confluent-controlcenter-6-1-0-1-metrics-trigger-measurement-rekey
_confluent-controlcenter-6-1-0-1-monitoring-aggregate-rekey-store-changelog
_confluent-controlcenter-6-1-0-1-monitoring-aggregate-rekey-store-repartition
_confluent-controlcenter-6-1-0-1-monitoring-message-rekey-store
_confluent-controlcenter-6-1-0-1-monitoring-trigger-event-rekey
_confluent-license
_confluent-metrics
_confluent-monitoring
_confluent-telemetry-metrics
_confluent_balancer_api_state
_confluent_balancer_broker_samples
_confluent_balancer_partition_samples
_schemas
connect-configs-dc2
connect-offsets-dc2
connect-status-dc2
topic1
topic2.replica
topic1:
{"userid":{"string":"User_2"},"dc":{"string":"dc2"}}
{"userid":{"string":"User_1"},"dc":{"string":"dc1"}}
{"userid":{"string":"User_6"},"dc":{"string":"dc2"}}
{"userid":{"string":"User_9"},"dc":{"string":"dc1"}}
{"userid":{"string":"User_9"},"dc":{"string":"dc2"}}
{"userid":{"string":"User_9"},"dc":{"string":"dc1"}}
{"userid":{"string":"User_9"},"dc":{"string":"dc2"}}
{"userid":{"string":"User_9"},"dc":{"string":"dc1"}}
{"userid":{"string":"User_9"},"dc":{"string":"dc2"}}
{"userid":{"string":"User_9"},"dc":{"string":"dc1"}}
Processed a total of 10 messages
topic2.replica:
{"registertime":{"long":1488571887136},"userid":{"string":"User_2"},"regionid":{"string":"Region_4"},"gender":{"string":"FEMALE"}}
{"registertime":{"long":1496554479008},"userid":{"string":"User_3"},"regionid":{"string":"Region_9"},"gender":{"string":"OTHER"}}
{"registertime":{"long":1515819037639},"userid":{"string":"User_1"},"regionid":{"string":"Region_7"},"gender":{"string":"FEMALE"}}
{"registertime":{"long":1498630829454},"userid":{"string":"User_9"},"regionid":{"string":"Region_5"},"gender":{"string":"FEMALE"}}
{"registertime":{"long":1491954362758},"userid":{"string":"User_6"},"regionid":{"string":"Region_6"},"gender":{"string":"FEMALE"}}
{"registertime":{"long":1498308706008},"userid":{"string":"User_2"},"regionid":{"string":"Region_2"},"gender":{"string":"OTHER"}}
{"registertime":{"long":1509409463384},"userid":{"string":"User_5"},"regionid":{"string":"Region_8"},"gender":{"string":"OTHER"}}
{"registertime":{"long":1494736574275},"userid":{"string":"User_4"},"regionid":{"string":"Region_4"},"gender":{"string":"OTHER"}}
{"registertime":{"long":1513254638109},"userid":{"string":"User_3"},"regionid":{"string":"Region_5"},"gender":{"string":"FEMALE"}}
{"registertime":{"long":1499607488391},"userid":{"string":"User_4"},"regionid":{"string":"Region_2"},"gender":{"string":"OTHER"}}
Processed a total of 10 messages
_schemas:
null
null
null
{"subject":"topic1-value","version":1,"id":1,"schema":"{\"type\":\"record\",\"name\":\"KsqlDataSourceSchema\",\"namespace\":\"io.confluent.ksql.avro_schemas\",\"fields\":[{\"name\":\"userid\",\"type\":[\"null\",\"string\"],\"default\":null},{\"name\":\"dc\",\"type\":[\"null\",\"string\"],\"default\":null}]}","deleted":false}
{"subject":"topic2-value","version":1,"id":2,"schema":"{\"type\":\"record\",\"name\":\"KsqlDataSourceSchema\",\"namespace\":\"io.confluent.ksql.avro_schemas\",\"fields\":[{\"name\":\"registertime\",\"type\":[\"null\",\"long\"],\"default\":null},{\"name\":\"userid\",\"type\":[\"null\",\"string\"],\"default\":null},{\"name\":\"regionid\",\"type\":[\"null\",\"string\"],\"default\":null},{\"name\":\"gender\",\"type\":[\"null\",\"string\"],\"default\":null}]}","deleted":false}
{"subject":"topic2.replica-value","version":1,"id":2,"schema":"{\"type\":\"record\",\"name\":\"KsqlDataSourceSchema\",\"namespace\":\"io.confluent.ksql.avro_schemas\",\"fields\":[{\"name\":\"registertime\",\"type\":[\"null\",\"long\"],\"default\":null},{\"name\":\"userid\",\"type\":[\"null\",\"string\"],\"default\":null},{\"name\":\"regionid\",\"type\":[\"null\",\"string\"],\"default\":null},{\"name\":\"gender\",\"type\":[\"null\",\"string\"],\"default\":null}]}","deleted":false}
[2021-01-04 19:17:26,336] ERROR Error processing message, terminating consumer process: (kafka.tools.ConsoleConsumer$)
org.apache.kafka.common.errors.TimeoutException
Processed a total of 6 messages
provenance info (cluster, topic, timestamp):
ZagAAEfORQG-lxwq6OsV5Q,topic1,1609787854055
ZagAAEfORQG-lxwq6OsV5Q,topic1,1609787854057
ZagAAEfORQG-lxwq6OsV5Q,topic1,1609787856052
ZagAAEfORQG-lxwq6OsV5Q,topic1,1609787857052
ZagAAEfORQG-lxwq6OsV5Q,topic1,1609787857054
Processed a total of 10 messages
timestamp info (group: topic-partition):
replicator-dc2-to-dc1-topic1: topic1-0 1609787867007
replicator-dc2-to-dc1-topic1: topic1-0 1609787877008
Processed a total of 2 messages
cluster id:
2qHo2TsdTIaTjvkCyf3qdw