ssl安全認證集群:
引數中除了常規的引數之後,需要傳入引數:
1. 「commonclientconfigs.security_protocal」,「sasl_plaintext」 ;
2. 「saslconfigs.sasl_mechanism」,「plain」 ;
3. 需要傳入安全集群的使用者名稱密碼:「sasl.jaas.config」,"org.apache.kafkacommon.security.plain.plainloginmodule required username = ? + password =? "
非安全認證集群 :
引數需要:
bootstrap.server :
enable.auto.commit:
session.timeout.ms:
max.poll.records:
key.deserializer:
value.deserializer:
為了防止賬號密碼被人破解,請將使用者名稱密碼使用stringbuilder進行拼接即可。
如需要通過配置不同的集群進行連線集群消費時,可採用多執行緒將兩種集群進行連線。 執行緒安全 不安全
hashmap 執行緒不安全 可以用concurrenthashmap,arraylist也有concurrent hashtable 執行緒安全,給每個方法都加上了synchronnized關鍵字。和concurrenthashmap的區別是加鎖粒度不同,不是很懂。stringbuilder 執行...
執行緒不安全
背景 執行緒不安全 sleep 模擬網路延遲 後多執行緒併發訪問同乙個資源 方法1 同步 塊 語法 synchronized 同步鎖 catch interruptedexception e 方法2 同步方法 使用synchronizd修飾的方法,就叫同步方法,保證a執行緒執行該方法的時候,其他執行...
執行緒安全與不安全
list介面下面有兩個實現 乙個是arraylist 另外乙個是vector 從原始碼的角度來看 vector的方法前加了,synchronized 關鍵字,也就是同步的意思,sun公司希望vector是執行緒安全的,而希望arraylist是高效的,缺點就是另外的優點。在 items size 的...