kafka: ====== I want to add this part ===== ...
# all-things-deployment
s
kafka: ====== I want to add this part ===== # client: # properties: # security.protocol: "SASL_SSL" # sasl.mechanism: "AWS_MSK_IAM" # sasl.jaas.config: software.amazon.msk.auth.iam.IAMLoginModule required; # sasl.client.callback.handler.class: software.amazon.msk.auth.iam.IAMClientCallbackHandler bootstrap: server: "b-2.elantestdatahubnew.q54zfo.c21.kafka.us-east-1.amazonaws.com:9098,b-1.elantestdatahubnew.q54zfo.c21.kafka.us-east-1.amazonaws.com:9098,b-3.elantestdatahubnew.q54zfo.c21.kafka.us-east-1.amazonaws.com:9098" zookeeper: server: "z-1.elantestdatahubnew.q54zfo.c21.kafka.us-east-1.amazonaws.com:2181,z-2.elantestdatahubnew.q54zfo.c21.kafka.us-east-1.amazonaws.com:2181,z-3.elantestdatahubnew.q54zfo.c21.kafka.us-east-1.amazonaws.com:2181" topics: #metadata_change_event_name: "MetadataChangeEvent_v4" # failed_metadata_change_event_name: "FailedMetadataChangeEvent_v4" # metadata_audit_event_name: "MetadataAuditEvent_v4" # datahub_usage_event_name: "DataHubUsageEvent_v1" # metadata_change_proposal_topic_name: "MetadataChangeProposal_v1" # failed_metadata_change_proposal_topic_name: "FailedMetadataChangeProposal_v1" # metadata_change_log_versioned_topic_name: "MetadataChangeLog_Versioned_v1" # metadata_change_log_timeseries_topic_name: "MetadataChangeLog_Timeseries_v1" # platform_event_topic_name: "PlatformEvent_v1" # datahub_upgrade_history_topic_name: "DataHubUpgradeHistory_v1" metadata_change_event_name: "_schemas" schemaregistry: type: AWS_GLUE glue: region: "us-east-1" registry: noor-new partitions: 3 replicationFactor: 3
help please
a
Hi- what’s the issue here? Are you getting errors when adding to recipes?
s
no errors on the recipes however could not add client.properties step 8 https://docs.aws.amazon.com/msk/latest/developerguide/create-topic.html
thanks for respons
I am working on eks
Logs Caused by: org.apache.kafka.common.errors.TimeoutException: The AdminClient thread has exited. Expected 1 brokers but found only 0. Trying to query Kafka for metadata again ... Error while getting broker list. java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.TimeoutException: The AdminClient thread has exited.