Untitled

mail@pastecode.io avatarunknown
plain_text
a month ago
6.4 kB
1
Indexable
Never
2023-08-23 17:25:55.613  WARN 393 --- [ntainer#0-0-C-1] org.apache.kafka.clients.NetworkClient   : [Consumer clientId=consumer-hobs-group-tibgenericeventGroup-1, groupId=hobs-group-tibgenericeventGroup] Bootstrap broker b-2.sitkafkacluster.mxb3zy.c2.kafka.ap-south-1.amazonaws.com:9098 (id: -1 rack: null) disconnected
2023-08-23 17:28:08.733  WARN 393 --- [ntainer#0-0-C-1] org.apache.kafka.clients.NetworkClient   : [Consumer clientId=consumer-hobs-group-tibgenericeventGroup-1, groupId=hobs-group-tibgenericeventGroup] Connection to node -2 (b-1.sitkafkacluster.mxb3zy.c2.kafka.ap-south-1.amazonaws.com/192.168.21.180:9098) could not be established. Broker may not be available.
2023-08-23 17:28:08.733  WARN 393 --- [ntainer#0-0-C-1] org.apache.kafka.clients.NetworkClient   : [Consumer clientId=consumer-hobs-group-tibgenericeventGroup-1, groupId=hobs-group-tibgenericeventGroup] Bootstrap broker b-1.sitkafkacluster.mxb3zy.c2.kafka.ap-south-1.amazonaws.com:9098 (id: -2 rack: null) disconnected

iam getting above error for below configurations
# server port
#server.port=8103

 

# kafka server config
#kafka.servers.bootstrap=${kafkahost}:${kafka_port}
#kafka.ssl.enabled = true

 

kafka.servers.bootstrap=b-2.sitkafkacluster.mxb3zy.c2.kafka.ap-south-1.amazonaws.com:9098,b-1.sitkafkacluster.mxb3zy.c2.kafka.ap-south-1.amazonaws.com:9098
kafka.ssl.enabled=false
#kafka.ssl.enabled = true

 

logging.level.com.tcs=INFO
logging.level.org.springframework=ERROR
enable.event.logging.intable=true
enable.enricheddata.odsstaging.directload=true
enable.clv.dataload=false
enable.clvcomputation=false
publishEnrichedDataForCLV=true
publishAuditData=true
#kafka topic configuration
tibgenericeventconsumer.topic.name=tibgenericevents
tibgenericeventconsumer.topic.groupname=hobs-group-tibgenericeventGroup

 

 

auditEventPublish.endpoint = https://apachehost/hobsrestgateway/tibgenericeventservice/eventconsumer/processEvent

 

#kafka topic configuration
tibfinalevents.topic.name=tibenrichedODSData
tibfinalevents.topic.groupname=hobs-group-tibenrichedODSData

 

spring.data.cassandra.contact-points=cassandrahost
spring.data.cassandra.keyspace-name=hobs_ods_staging
spring.data.cassandra.port = 9042
spring.data.cassandra.username=hobs_ods_staging
spring.data.cassandra.password=hobs_ods_staging
spring.data.cassandra.show.cql=True
spring.main.allow-bean-definition-overriding=true
spring.data.cassandra.local-datacenter=dc1

 

# Node Enricher
#genericevents.odsenricher.endpoint=https://apachehost/odsenricher/?/{value}
genericevents.odsenricher.endpoint=http://192.168.21.100:5580/?/{value}
clvcomputation.endpoint = https://apachehost/HOBSAnalytics/dataservice/computeCLV?

 

truststore.location=${kafka_truststore}
keystore.location=${kafka_keystore}
SSL.pass=${kafka_key_pwd}
truststore.pass=${kafka_truststore_pwd}
keystore.pass=${kafka_keystore_pwd}
#max.block.in.ms=${kafka_timeout_inms}

 

 

spring.datasource.timeBetweenEvictionRunsMillis = 60000
spring.main.allow-circular-references = true

 

#odsStagingEvents = ["addCustomer","updateCustomer","addInteraction","addContact","updateContact","addAccount","updateAccount","createOrder","updateOrder","updateOrderLines","orderCompletion","createWorkItem","closeWorkItem","updateWorkItem","workItemEscalation","createLead","updateLead","orderLineCancellation"]


odsStagingEvents = ["addCustomer","updateCustomer","addInteraction","addContact","updateContact","addAccount","updateAccount","createOrder","updateOrder","orderCompletion","createWorkItem","closeWorkItem","updateWorkItem","workItemEscalation","createLead","updateLead","orderLineCancellation"]

 

auditSelectiveColumns=true
auditEnabledColumns = {"hos_party" \: ["hosp_dob","hosp_fname","hosp_gender","hosp_lname","hosp_mname","hosp_organization_corp_code","hosp_organization_corp_type","hosp_organization_id","hosp_organization_name","hosp_organization_short_code","hosp_organization_tin","hosp_party_extn_attributes","hosp_title"],"hos_address" \: ["hosad_address_line1","hosad_zip_code","hosad_address_line2","hosad_address_line3","hosad_address_category","hosad_address_extn_attributes","hosad_city_cd","hosad_country_cd","hosad_state_cd","hosad_street","hosad_zip_code"],"hos_party_medium" \: ["hospm_day_time_ph_no","hospm_fax_number","hospm_preferred_contact_time","hospm_alt_email_id1","hospm_alt_email_id2","hospm_party_nbr","hospm_address_id","hospm_party_type","hospm_fname","hospm_mname","hospm_lname","hospm_org_name","hospm_short_name","hospm_normal_name","hospm_address_category","hospm_address_line1","hospm_address_line2","hospm_address_line3","hospm_address_line4","hospm_address_type","hospm_city_cd","hospm_country_cd","hospm_state_cd","hospm_street","hospm_zip_code"],"hos_account" \: ["hosa_account_name","hosa_account_extn_attributes","hosa_account_pin","hosa_accounting_type","hosa_acct_segment_id","hosa_acct_type_id","hosa_ar_status_id","hosa_ar_sub_status_id","hosa_base_currency","hosa_bill_cycle","hosa_bill_cycle_date","hosa_bill_disp_method","hosa_bill_email","hosa_bill_email_suppress_yn","hosa_bill_format","hosa_bill_frequency","hosa_bill_hub","hosa_bill_period","hosa_bill_print","hosa_bill_sub_state","hosa_billable_indicator","hosa_billing_language","hosa_budget_centre_id","hosa_col_type_id","hosa_cost_centre_id","hosa_credit_rating_id","hosa_dca_id","hosa_def_credit_limit","hosa_disconnection_reason","hosa_inst_remarks","hosa_internal_flag","hosa_key_attr_change","hosa_mode_of_comm","hosa_paper_hold","hosa_parent_acct_id","hosa_payable_indicator","hosa_payment_method","hosa_payment_plan_ind","hosa_promise_to_pay_ind","hosa_quote_ref_id","hosa_root_acct_id","hosa_sales_code",hosa_secondary_currency","hosa_statement_indicator","hosa_tax_code","hosa_timezone","hosa_vip_code"],"hos_customer" \: ["hosc_campaign_id","hosc_care_level","hosc_cust_mkt_id","hosc_customer_extn_attributes","hosc_customer_segment_id","hosc_customer_sub_type","hosc_customer_type","hosc_dealer_code","hosc_external_customer_id1","hosc_external_customer_id2","hosc_loyalty_account_id","hosc_reason_code","hosc_reason_description","hosc_reseller_id","hosc_selfcare_username","hosc_updated_reason_code","hosc_updated_reason_description"]}

 

tibgenericeventconsumer.taskexecutor.corepoolsize=50
tibgenericeventconsumer.taskexecutor.maxpoolsize =100
tibgenericeventconsumer.taskexecutor.queuecapacity =150