[root@VM-0-5-centos cp-demo-6.0.1-post]# ./scripts/start.sh
Removing network cp-demo-601-post_default
Environment parameters
REPOSITORY=confluentinc
CONNECTOR_VERSION=6.0.1
CLEAN=false
VIZ=true
C3_KSQLDB_HTTPS=false
Creating network "cp-demo-601-post_default" with the default driver
Creating openldap ... done
openldap is up-to-date
Creating zookeeper ... done
Creating kafka2 ... done
Creating kafka1 ... done
Creating tools ... done
Waiting up to 120 seconds for MDS to start
......
Creating role bindings for principals
# Login
spawn confluent login --ca-cert-path /etc/kafka/secrets/snakeoil-ca-1.crt --url https://kafka1:8091
superUser
Updates are available for confluent from (current: v1.18.0, latest: v1.22.0).
To view release notes and install them, please run:
$ confluent update
Enter your Confluent credentials:
Username: Password: *********
Logged in as "superUser".
Creating role bindings for Super User
+--------------+----------------+
| Principal | User:superUser |
| Role | SystemAdmin |
| ResourceType | Cluster |
+--------------+----------------+
+--------------+----------------+
| Principal | User:superUser |
| Role | SystemAdmin |
| ResourceType | Cluster |
+--------------+----------------+
+--------------+----------------+
| Principal | User:superUser |
| Role | SystemAdmin |
| ResourceType | Cluster |
+--------------+----------------+
+--------------+----------------+
| Principal | User:superUser |
| Role | SystemAdmin |
| ResourceType | Cluster |
+--------------+----------------+
Creating role bindings for Schema Registry
+--------------+-------------------------+
| Principal | User:schemaregistryUser |
| Role | SecurityAdmin |
| ResourceType | Cluster |
+--------------+-------------------------+
+--------------+-------------------------+
| Principal | User:schemaregistryUser |
| Role | ResourceOwner |
| ResourceType | Topic |
| Name | _schemas |
| PatternType | LITERAL |
+--------------+-------------------------+
+--------------+-------------------------+
| Principal | User:schemaregistryUser |
| Role | ResourceOwner |
| ResourceType | Group |
| Name | schema-registry |
| PatternType | LITERAL |
+--------------+-------------------------+
+--------------+-------------------------+
| Principal | User:schemaregistryUser |
| Role | DeveloperRead |
| ResourceType | Topic |
| Name | _confluent-license |
| PatternType | LITERAL |
+--------------+-------------------------+
+--------------+-------------------------+
| Principal | User:schemaregistryUser |
| Role | DeveloperWrite |
| ResourceType | Topic |
| Name | _confluent-license |
| PatternType | LITERAL |
+--------------+-------------------------+
Creating role bindings for Connect Admin
+--------------+-------------------+
| Principal | User:connectAdmin |
| Role | SecurityAdmin |
| ResourceType | Cluster |
+--------------+-------------------+
+--------------+-------------------+
| Principal | User:connectAdmin |
| Role | ResourceOwner |
| ResourceType | Topic |
| Name | connect-configs |
| PatternType | LITERAL |
+--------------+-------------------+
+--------------+-------------------+
| Principal | User:connectAdmin |
| Role | ResourceOwner |
| ResourceType | Topic |
| Name | connect-offsets |
| PatternType | LITERAL |
+--------------+-------------------+
+--------------+-------------------+
| Principal | User:connectAdmin |
| Role | ResourceOwner |
| ResourceType | Topic |
| Name | connect-statuses |
| PatternType | LITERAL |
+--------------+-------------------+
+--------------+-------------------+
| Principal | User:connectAdmin |
| Role | ResourceOwner |
| ResourceType | Group |
| Name | connect-cluster |
| PatternType | LITERAL |
+--------------+-------------------+
+--------------+-----------------------+
| Principal | User:connectAdmin |
| Role | ResourceOwner |
| ResourceType | Topic |
| Name | _confluent-monitoring |
| PatternType | LITERAL |
+--------------+-----------------------+
+--------------+--------------------+
| Principal | User:connectAdmin |
| Role | ResourceOwner |
| ResourceType | Topic |
| Name | _confluent-secrets |
| PatternType | LITERAL |
+--------------+--------------------+
+--------------+-------------------+
| Principal | User:connectAdmin |
| Role | ResourceOwner |
| ResourceType | Group |
| Name | secret-registry |
| PatternType | LITERAL |
+--------------+-------------------+
Creating role bindings for wikipedia-sse connector
+--------------+-------------------------+
| Principal | User:connectorSubmitter |
| Role | ResourceOwner |
| ResourceType | Connector |
| Name | wikipedia-sse |
| PatternType | LITERAL |
+--------------+-------------------------+
+--------------+------------------+
| Principal | User:connectorSA |
| Role | ResourceOwner |
| ResourceType | Topic |
| Name | wikipedia |
| PatternType | PREFIXED |
+--------------+------------------+
+--------------+------------------+
| Principal | User:connectorSA |
| Role | ResourceOwner |
| ResourceType | Subject |
| Name | wikipedia |
| PatternType | PREFIXED |
+--------------+------------------+
+--------------+------------------+
| Principal | User:connectorSA |
| Role | DeveloperWrite |
| ResourceType | Cluster |
| Name | kafka-cluster |
| PatternType | LITERAL |
+--------------+------------------+
Creating role bindings for replicate-topic connector
+--------------+-------------------------+
| Principal | User:connectorSubmitter |
| Role | ResourceOwner |
| ResourceType | Connector |
| Name | replicate-topic |
| PatternType | LITERAL |
+--------------+-------------------------+
+--------------+------------------+
| Principal | User:connectorSA |
| Role | ResourceOwner |
| ResourceType | Topic |
| Name | _confluent |
| PatternType | PREFIXED |
+--------------+------------------+
+--------------+--------------------+
| Principal | User:connectorSA |
| Role | ResourceOwner |
| ResourceType | Group |
| Name | connect-replicator |
| PatternType | LITERAL |
+--------------+--------------------+
Creating role bindings for elasticsearch-ksqldb connector
+--------------+-------------------------+
| Principal | User:connectorSubmitter |
| Role | ResourceOwner |
| ResourceType | Connector |
| Name | elasticsearch-ksqldb |
| PatternType | LITERAL |
+--------------+-------------------------+
+--------------+------------------------------+
| Principal | User:connectorSA |
| Role | ResourceOwner |
| ResourceType | Group |
| Name | connect-elasticsearch-ksqldb |
| PatternType | LITERAL |
+--------------+------------------------------+
+--------------+------------------+
| Principal | User:connectorSA |
| Role | ResourceOwner |
| ResourceType | Topic |
| Name | WIKIPEDIA |
| PatternType | PREFIXED |
+--------------+------------------+
+--------------+------------------+
| Principal | User:connectorSA |
| Role | ResourceOwner |
| ResourceType | Subject |
| Name | WIKIPEDIA |
| PatternType | PREFIXED |
+--------------+------------------+
Creating role bindings for ksqlDB Admin
+--------------+------------------+
| Principal | User:ksqlDBAdmin |
| Role | ResourceOwner |
| ResourceType | KsqlCluster |
| Name | ksql-cluster |
| PatternType | LITERAL |
+--------------+------------------+
+--------------+------------------------------+
| Principal | User:ksqlDBAdmin |
| Role | DeveloperRead |
| ResourceType | Group |
| Name | _confluent-ksql-ksql-cluster |
| PatternType | PREFIXED |
+--------------+------------------------------+
+--------------+------------------------------+
| Principal | User:ksqlDBAdmin |
| Role | ResourceOwner |
| ResourceType | Topic |
| Name | _confluent-ksql-ksql-cluster |
| PatternType | PREFIXED |
+--------------+------------------------------+
+--------------+------------------------------+
| Principal | User:ksqlDBAdmin |
| Role | ResourceOwner |
| ResourceType | Subject |
| Name | _confluent-ksql-ksql-cluster |
| PatternType | PREFIXED |
+--------------+------------------------------+
+--------------+-----------------------+
| Principal | User:ksqlDBAdmin |
| Role | ResourceOwner |
| ResourceType | Topic |
| Name | _confluent-monitoring |
| PatternType | LITERAL |
+--------------+-----------------------+
+--------------+---------------------------------+
| Principal | User:ksqlDBAdmin |
| Role | ResourceOwner |
| ResourceType | Topic |
| Name | ksql-clusterksql_processing_log |
| PatternType | LITERAL |
+--------------+---------------------------------+
+--------------+------------------+
| Principal | User:ksqlDBAdmin |
| Role | DeveloperRead |
| ResourceType | Topic |
| Name | wikipedia.parsed |
| PatternType | LITERAL |
+--------------+------------------+
+--------------+------------------+
| Principal | User:ksqlDBAdmin |
| Role | ResourceOwner |
| ResourceType | Topic |
| Name | WIKIPEDIA |
| PatternType | PREFIXED |
+--------------+------------------+
+--------------+------------------+
| Principal | User:ksqlDBAdmin |
| Role | ResourceOwner |
| ResourceType | Topic |
| Name | EN_WIKIPEDIA |
| PatternType | PREFIXED |
+--------------+------------------+
+--------------+------------------+
| Principal | User:ksqlDBAdmin |
| Role | ResourceOwner |
| ResourceType | TransactionalId |
| Name | ksql-cluster |
| PatternType | LITERAL |
+--------------+------------------+
+--------------+------------------+
| Principal | User:ksqlDBAdmin |
| Role | ResourceOwner |
| ResourceType | Subject |
| Name | wikipedia |
| PatternType | PREFIXED |
+--------------+------------------+
+--------------+------------------+
| Principal | User:ksqlDBAdmin |
| Role | ResourceOwner |
| ResourceType | Subject |
| Name | WIKIPEDIA |
| PatternType | PREFIXED |
+--------------+------------------+
+--------------+------------------+
| Principal | User:ksqlDBAdmin |
| Role | ResourceOwner |
| ResourceType | Subject |
| Name | EN_WIKIPEDIA |
| PatternType | PREFIXED |
+--------------+------------------+
+--------------+------------------+
| Principal | User:ksqlDBAdmin |
| Role | ResourceOwner |
| ResourceType | Subject |
| Name | WIKIPEDIA |
| PatternType | PREFIXED |
+--------------+------------------+
+--------------+------------------+
| Principal | User:ksqlDBAdmin |
| Role | ResourceOwner |
| ResourceType | Subject |
| Name | EN_WIKIPEDIA |
| PatternType | PREFIXED |
+--------------+------------------+
+--------------+------------------+
| Principal | User:ksqlDBAdmin |
| Role | DeveloperWrite |
| ResourceType | Cluster |
| Name | kafka-cluster |
| PatternType | LITERAL |
+--------------+------------------+
Creating role bindings for ksqlDB User
+--------------+-----------------+
| Principal | User:ksqlDBUser |
| Role | DeveloperWrite |
| ResourceType | KsqlCluster |
| Name | ksql-cluster |
| PatternType | LITERAL |
+--------------+-----------------+
+--------------+------------------------------+
| Principal | User:ksqlDBUser |
| Role | DeveloperRead |
| ResourceType | Group |
| Name | _confluent-ksql-ksql-cluster |
| PatternType | PREFIXED |
+--------------+------------------------------+
+--------------+------------------------------+
| Principal | User:ksqlDBUser |
| Role | ResourceOwner |
| ResourceType | Topic |
| Name | _confluent-ksql-ksql-cluster |
| PatternType | PREFIXED |
+--------------+------------------------------+
+--------------+------------------------------+
| Principal | User:ksqlDBUser |
| Role | ResourceOwner |
| ResourceType | Subject |
| Name | _confluent-ksql-ksql-cluster |
| PatternType | PREFIXED |
+--------------+------------------------------+
+--------------+---------------------------------+
| Principal | User:ksqlDBUser |
| Role | DeveloperRead |
| ResourceType | Topic |
| Name | ksql-clusterksql_processing_log |
| PatternType | LITERAL |
+--------------+---------------------------------+
+--------------+------------------+
| Principal | User:ksqlDBUser |
| Role | DeveloperRead |
| ResourceType | Topic |
| Name | wikipedia.parsed |
| PatternType | LITERAL |
+--------------+------------------+
+--------------+-----------------+
| Principal | User:ksqlDBUser |
| Role | ResourceOwner |
| ResourceType | Subject |
| Name | wikipedia |
| PatternType | PREFIXED |
+--------------+-----------------+
+--------------+-----------------+
| Principal | User:ksqlDBUser |
| Role | ResourceOwner |
| ResourceType | Topic |
| Name | WIKIPEDIA |
| PatternType | PREFIXED |
+--------------+-----------------+
+--------------+-----------------+
| Principal | User:ksqlDBUser |
| Role | ResourceOwner |
| ResourceType | Topic |
| Name | EN_WIKIPEDIA |
| PatternType | PREFIXED |
+--------------+-----------------+
+--------------+-----------------+
| Principal | User:ksqlDBUser |
| Role | ResourceOwner |
| ResourceType | Subject |
| Name | WIKIPEDIA |
| PatternType | PREFIXED |
+--------------+-----------------+
+--------------+-----------------+
| Principal | User:ksqlDBUser |
| Role | ResourceOwner |
| ResourceType | Subject |
| Name | EN_WIKIPEDIA |
| PatternType | PREFIXED |
+--------------+-----------------+
+--------------+-----------------+
| Principal | User:ksqlDBUser |
| Role | DeveloperWrite |
| ResourceType | Cluster |
| Name | kafka-cluster |
| PatternType | LITERAL |
+--------------+-----------------+
Creating role bindings for ksqlDB Server (used for ksqlDB Processing Log)
+--------------+-----------------------------------+
| Principal | User:controlCenterAndKsqlDBServer |
| Role | ResourceOwner |
| ResourceType | Topic |
| Name | ksql-clusterksql_processing_log |
| PatternType | LITERAL |
+--------------+-----------------------------------+
Creating role bindings for Control Center
+--------------+-------------------------+
| Principal | User:controlcenterAdmin |
| Role | SystemAdmin |
| ResourceType | Cluster |
+--------------+-------------------------+
Creating role bindings for Rest Proxy
+--------------+--------------------+
| Principal | User:restAdmin |
| Role | DeveloperRead |
| ResourceType | Topic |
| Name | _confluent-license |
| PatternType | LITERAL |
+--------------+--------------------+
+--------------+--------------------+
| Principal | User:restAdmin |
| Role | DeveloperWrite |
| ResourceType | Topic |
| Name | _confluent-license |
| PatternType | LITERAL |
+--------------+--------------------+
Creating role bindings for the streams-demo application
+--------------+---------------+
| Principal | User:appSA |
| Role | ResourceOwner |
| ResourceType | Group |
| Name | wikipedia |
| PatternType | PREFIXED |
+--------------+---------------+
+--------------+---------------+
| Principal | User:appSA |
| Role | ResourceOwner |
| ResourceType | Group |
| Name | app |
| PatternType | PREFIXED |
+--------------+---------------+
+--------------+---------------+
| Principal | User:appSA |
| Role | ResourceOwner |
| ResourceType | Topic |
| Name | wikipedia |
| PatternType | PREFIXED |
+--------------+---------------+
+--------------+---------------+
| Principal | User:appSA |
| Role | ResourceOwner |
| ResourceType | Topic |
| Name | users |
| PatternType | LITERAL |
+--------------+---------------+
+--------------+-----------------------+
| Principal | User:appSA |
| Role | ResourceOwner |
| ResourceType | Topic |
| Name | _confluent-monitoring |
| PatternType | LITERAL |
+--------------+-----------------------+
+--------------+---------------+
| Principal | User:appSA |
| Role | ResourceOwner |
| ResourceType | Subject |
| Name | wikipedia |
| PatternType | PREFIXED |
+--------------+---------------+
Creating role bindings for the listen client application
+--------------+-------------------+
| Principal | User:clientListen |
| Role | ResourceOwner |
| ResourceType | Group |
| Name | listen-consumer |
| PatternType | PREFIXED |
+--------------+-------------------+
+--------------+-------------------+
| Principal | User:clientListen |
| Role | ResourceOwner |
| ResourceType | Topic |
| Name | wikipedia |
| PatternType | PREFIXED |
+--------------+-------------------+
+--------------+-------------------+
| Principal | User:clientListen |
| Role | ResourceOwner |
| ResourceType | Topic |
| Name | WIKIPEDIA |
| PatternType | PREFIXED |
+--------------+-------------------+
+--------------+-------------------+
| Principal | User:clientListen |
| Role | ResourceOwner |
| ResourceType | Topic |
| Name | EN_WIKIPEDIA |
| PatternType | LITERAL |
+--------------+-------------------+
+--------------+-------------------+
| Principal | User:clientListen |
| Role | ResourceOwner |
| ResourceType | Subject |
| Name | wikipedia |
| PatternType | PREFIXED |
+--------------+-------------------+
+--------------+-------------------+
| Principal | User:clientListen |
| Role | ResourceOwner |
| ResourceType | Subject |
| Name | WIKIPEDIA |
| PatternType | PREFIXED |
+--------------+-------------------+
+--------------+-------------------+
| Principal | User:clientListen |
| Role | ResourceOwner |
| ResourceType | Subject |
| Name | EN_WIKIPEDIA |
| PatternType | PREFIXED |
+--------------+-------------------+
Cluster IDs:
kafka cluster id: NeM9wyv9RSK6dUMILAsN_A
connect cluster id: connect-cluster
schema registry cluster id: schema-registry
ksql cluster id: ksql-cluster
Cluster IDs as environment variables:
export KAFKA_ID=NeM9wyv9RSK6dUMILAsN_A ; export CONNECT_ID=connect-cluster ; export SR_ID=schema-registry ; export KSQLDB_ID=ksql-cluster
Principals:
super user account: User:superUser
Schema Registry user: User:schemaregistryUser
Connect Admin: User:connectAdmin
Connector Submitter: User:connectorSubmitter
Connector Principal: User:connectorSA
ksqlDB Admin: User:ksqlDBAdmin
ksqlDB User: User:ksqlDBUser
C3 Admin: User:controlcenterAdmin
Rest Admin: User:restAdmin
Client service account: User:appSA
Listen Client service account: User:clientListen
Completed updating config for topic _confluent-metadata-auth.
openldap is up-to-date
zookeeper is up-to-date
kafka1 is up-to-date
kafka2 is up-to-date
Creating schemaregistry ... done
Creating connect ... done
Creating control-center ... done
Create topics in Kafka cluster:
KAFKA_CLUSTER_ID: NeM9wyv9RSK6dUMILAsN_A
response code: 201
{
"kind": "KafkaTopic",
"metadata": {
"self": "https://kafka1:8091/kafka/v3/clusters/NeM9wyv9RSK6dUMILAsN_A/topics/users",
"resource_name": "crn:///kafka=NeM9wyv9RSK6dUMILAsN_A/topic=users"
},
"cluster_id": "NeM9wyv9RSK6dUMILAsN_A",
"topic_name": "users",
"is_internal": false,
"replication_factor": 2,
"partitions": {
"related": "https://kafka1:8091/kafka/v3/clusters/NeM9wyv9RSK6dUMILAsN_A/topics/users/partitions"
},
"configs": {
"related": "https://kafka1:8091/kafka/v3/clusters/NeM9wyv9RSK6dUMILAsN_A/topics/users/configs"
},
"partition_reassignments": {
"related": "https://kafka1:8091/kafka/v3/clusters/NeM9wyv9RSK6dUMILAsN_A/topics/users/partitions/-/reassignment"
}
}
response code: 201
{
"kind": "KafkaTopic",
"metadata": {
"self": "https://kafka1:8091/kafka/v3/clusters/NeM9wyv9RSK6dUMILAsN_A/topics/wikipedia.parsed",
"resource_name": "crn:///kafka=NeM9wyv9RSK6dUMILAsN_A/topic=wikipedia.parsed"
},
"cluster_id": "NeM9wyv9RSK6dUMILAsN_A",
"topic_name": "wikipedia.parsed",
"is_internal": false,
"replication_factor": 2,
"partitions": {
"related": "https://kafka1:8091/kafka/v3/clusters/NeM9wyv9RSK6dUMILAsN_A/topics/wikipedia.parsed/partitions"
},
"configs": {
"related": "https://kafka1:8091/kafka/v3/clusters/NeM9wyv9RSK6dUMILAsN_A/topics/wikipedia.parsed/configs"
},
"partition_reassignments": {
"related": "https://kafka1:8091/kafka/v3/clusters/NeM9wyv9RSK6dUMILAsN_A/topics/wikipedia.parsed/partitions/-/reassignment"
}
}
response code: 201
{
"kind": "KafkaTopic",
"metadata": {
"self": "https://kafka1:8091/kafka/v3/clusters/NeM9wyv9RSK6dUMILAsN_A/topics/wikipedia.parsed.count-by-domain",
"resource_name": "crn:///kafka=NeM9wyv9RSK6dUMILAsN_A/topic=wikipedia.parsed.count-by-domain"
},
"cluster_id": "NeM9wyv9RSK6dUMILAsN_A",
"topic_name": "wikipedia.parsed.count-by-domain",
"is_internal": false,
"replication_factor": 2,
"partitions": {
"related": "https://kafka1:8091/kafka/v3/clusters/NeM9wyv9RSK6dUMILAsN_A/topics/wikipedia.parsed.count-by-domain/partitions"
},
"configs": {
"related": "https://kafka1:8091/kafka/v3/clusters/NeM9wyv9RSK6dUMILAsN_A/topics/wikipedia.parsed.count-by-domain/configs"
},
"partition_reassignments": {
"related": "https://kafka1:8091/kafka/v3/clusters/NeM9wyv9RSK6dUMILAsN_A/topics/wikipedia.parsed.count-by-domain/partitions/-/reassignment"
}
}
response code: 201
{
"kind": "KafkaTopic",
"metadata": {
"self": "https://kafka1:8091/kafka/v3/clusters/NeM9wyv9RSK6dUMILAsN_A/topics/wikipedia.failed",
"resource_name": "crn:///kafka=NeM9wyv9RSK6dUMILAsN_A/topic=wikipedia.failed"
},
"cluster_id": "NeM9wyv9RSK6dUMILAsN_A",
"topic_name": "wikipedia.failed",
"is_internal": false,
"replication_factor": 2,
"partitions": {
"related": "https://kafka1:8091/kafka/v3/clusters/NeM9wyv9RSK6dUMILAsN_A/topics/wikipedia.failed/partitions"
},
"configs": {
"related": "https://kafka1:8091/kafka/v3/clusters/NeM9wyv9RSK6dUMILAsN_A/topics/wikipedia.failed/configs"
},
"partition_reassignments": {
"related": "https://kafka1:8091/kafka/v3/clusters/NeM9wyv9RSK6dUMILAsN_A/topics/wikipedia.failed/partitions/-/reassignment"
}
}
response code: 201
{
"kind": "KafkaTopic",
"metadata": {
"self": "https://kafka1:8091/kafka/v3/clusters/NeM9wyv9RSK6dUMILAsN_A/topics/WIKIPEDIABOT",
"resource_name": "crn:///kafka=NeM9wyv9RSK6dUMILAsN_A/topic=WIKIPEDIABOT"
},
"cluster_id": "NeM9wyv9RSK6dUMILAsN_A",
"topic_name": "WIKIPEDIABOT",
"is_internal": false,
"replication_factor": 2,
"partitions": {
"related": "https://kafka1:8091/kafka/v3/clusters/NeM9wyv9RSK6dUMILAsN_A/topics/WIKIPEDIABOT/partitions"
},
"configs": {
"related": "https://kafka1:8091/kafka/v3/clusters/NeM9wyv9RSK6dUMILAsN_A/topics/WIKIPEDIABOT/configs"
},
"partition_reassignments": {
"related": "https://kafka1:8091/kafka/v3/clusters/NeM9wyv9RSK6dUMILAsN_A/topics/WIKIPEDIABOT/partitions/-/reassignment"
}
}
response code: 201
{
"kind": "KafkaTopic",
"metadata": {
"self": "https://kafka1:8091/kafka/v3/clusters/NeM9wyv9RSK6dUMILAsN_A/topics/WIKIPEDIANOBOT",
"resource_name": "crn:///kafka=NeM9wyv9RSK6dUMILAsN_A/topic=WIKIPEDIANOBOT"
},
"cluster_id": "NeM9wyv9RSK6dUMILAsN_A",
"topic_name": "WIKIPEDIANOBOT",
"is_internal": false,
"replication_factor": 2,
"partitions": {
"related": "https://kafka1:8091/kafka/v3/clusters/NeM9wyv9RSK6dUMILAsN_A/topics/WIKIPEDIANOBOT/partitions"
},
"configs": {
"related": "https://kafka1:8091/kafka/v3/clusters/NeM9wyv9RSK6dUMILAsN_A/topics/WIKIPEDIANOBOT/configs"
},
"partition_reassignments": {
"related": "https://kafka1:8091/kafka/v3/clusters/NeM9wyv9RSK6dUMILAsN_A/topics/WIKIPEDIANOBOT/partitions/-/reassignment"
}
}
response code: 201
{
"kind": "KafkaTopic",
"metadata": {
"self": "https://kafka1:8091/kafka/v3/clusters/NeM9wyv9RSK6dUMILAsN_A/topics/EN_WIKIPEDIA_GT_1",
"resource_name": "crn:///kafka=NeM9wyv9RSK6dUMILAsN_A/topic=EN_WIKIPEDIA_GT_1"
},
"cluster_id": "NeM9wyv9RSK6dUMILAsN_A",
"topic_name": "EN_WIKIPEDIA_GT_1",
"is_internal": false,
"replication_factor": 2,
"partitions": {
"related": "https://kafka1:8091/kafka/v3/clusters/NeM9wyv9RSK6dUMILAsN_A/topics/EN_WIKIPEDIA_GT_1/partitions"
},
"configs": {
"related": "https://kafka1:8091/kafka/v3/clusters/NeM9wyv9RSK6dUMILAsN_A/topics/EN_WIKIPEDIA_GT_1/configs"
},
"partition_reassignments": {
"related": "https://kafka1:8091/kafka/v3/clusters/NeM9wyv9RSK6dUMILAsN_A/topics/EN_WIKIPEDIA_GT_1/partitions/-/reassignment"
}
}
response code: 201
{
"kind": "KafkaTopic",
"metadata": {
"self": "https://kafka1:8091/kafka/v3/clusters/NeM9wyv9RSK6dUMILAsN_A/topics/EN_WIKIPEDIA_GT_1_COUNTS",
"resource_name": "crn:///kafka=NeM9wyv9RSK6dUMILAsN_A/topic=EN_WIKIPEDIA_GT_1_COUNTS"
},
"cluster_id": "NeM9wyv9RSK6dUMILAsN_A",
"topic_name": "EN_WIKIPEDIA_GT_1_COUNTS",
"is_internal": false,
"replication_factor": 2,
"partitions": {
"related": "https://kafka1:8091/kafka/v3/clusters/NeM9wyv9RSK6dUMILAsN_A/topics/EN_WIKIPEDIA_GT_1_COUNTS/partitions"
},
"configs": {
"related": "https://kafka1:8091/kafka/v3/clusters/NeM9wyv9RSK6dUMILAsN_A/topics/EN_WIKIPEDIA_GT_1_COUNTS/configs"
},
"partition_reassignments": {
"related": "https://kafka1:8091/kafka/v3/clusters/NeM9wyv9RSK6dUMILAsN_A/topics/EN_WIKIPEDIA_GT_1_COUNTS/partitions/-/reassignment"
}
}
Waiting up to 300 seconds for Confluent Control Center to start
........
Confluent Control Center modifications:
/new_pan/cp-demo-6.0.1-post/scripts/helper/control-center-modifications.sh:行4: jq: 未找到命令
(23) Failed writing body
/new_pan/cp-demo-6.0.1-post/scripts/helper/control-center-modifications.sh:行7: jq: 未找到命令
(23) Failed writing body
Rename the cluster in Control Center from to Kafka Raleigh
Configure triggers and actions in Control Center:
Error 401 Bearer realm="",error="invalid_request"
HTTP ERROR 401 Bearer realm="",error="invalid_request"
URI: | /2.0/alerts/triggers |
STATUS: | 401 |
MESSAGE: | Bearer realm="",error="invalid_request" |
SERVLET: | default |
Error 401 Bearer realm="",error="invalid_request"
HTTP ERROR 401 Bearer realm="",error="invalid_request"
URI: | /2.0/alerts/triggers |
STATUS: | 401 |
MESSAGE: | Bearer realm="",error="invalid_request" |
SERVLET: | default |
/new_pan/cp-demo-6.0.1-post/scripts/helper/control-center-modifications.sh:行19: jq: 未找到命令
(23) Failed writing body
/new_pan/cp-demo-6.0.1-post/scripts/helper/control-center-modifications.sh:行19: jq: 未找到命令
(23) Failed writing body
Error 401 Bearer realm="",error="invalid_request"
HTTP ERROR 401 Bearer realm="",error="invalid_request"
URI: | /2.0/alerts/actions |
STATUS: | 401 |
MESSAGE: | Bearer realm="",error="invalid_request" |
SERVLET: | default |
Waiting up to 240 seconds for Connect to start
.
zookeeper is up-to-date
openldap is up-to-date
kafka1 is up-to-date
kafka2 is up-to-date
schemaregistry is up-to-date
connect is up-to-date
Creating restproxy ... done
Creating ksqldb-server ... done
Creating ksqldb-cli ... done
...
Start streaming from the Wikipedia SSE source connector:
{"name":"wikipedia-sse","config":{"connector.class":"com.github.cjmatta.kafka.connect.sse.ServerSentEventsSourceConnector","sse.uri":"https://stream.wikimedia.org/v2/stream/recentchange","topic":"wikipedia.parsed","transforms":"extractData, parseJSON","transforms.extractData.type":"org.apache.kafka.connect.transforms.ExtractField$Value","transforms.extractData.field":"data","transforms.parseJSON.type":"com.github.jcustenborder.kafka.connect.json.FromJson$Value","transforms.parseJSON.json.exclude.locations":"#/properties/log_params,#/properties/$schema,#/$schema","transforms.parseJSON.json.schema.location":"Url","transforms.parseJSON.json.schema.url":"https://raw.githubusercontent.com/wikimedia/mediawiki-event-schemas/master/jsonschema/mediawiki/recentchange/1.0.0.json","transforms.parseJSON.json.schema.validation.enabled":"false","producer.interceptor.classes":"io.confluent.monitoring.clients.interceptor.MonitoringProducerInterceptor","value.converter":"io.confluent.connect.avro.AvroConverter","value.converter.schema.registry.url":"https://schemaregistry:8085","value.converter.schema.registry.ssl.truststore.location":"/etc/kafka/secrets/kafka.client.truststore.jks","value.converter.schema.registry.ssl.truststore.password":"confluent","value.converter.basic.auth.credentials.source":"USER_INFO","value.converter.basic.auth.user.info":"connectorSA:connectorSA","producer.override.sasl.jaas.config":"org.apache.kafka.common.security.oauthbearer.OAuthBearerLoginModule required username=\"connectorSA\" password=\"connectorSA\" metadataServerUrls=\"https://kafka1:8091,https://kafka2:8092\";","tasks.max":"1","name":"wikipedia-sse"},"tasks":[],"type":"source"}
Waiting up to 120 seconds for subject wikipedia.parsed-value (for topic wikipedia.parsed) to be registered in Schema Registry
........................ERROR: Failed after 120 seconds. Please troubleshoot and run again. For troubleshooting instructions see https://docs.confluent.io/current/tutorials/cp-demo/docs/index.html#troubleshooting
[root@VM-0-5-centos cp-demo-6.0.1-post]#