排查到的原因 配置的IP跟host 不對 錯誤排查： 服務器防火牆已關閉，本地telnet連接9092端口沒問題 kafka配置文件 listeners=PLAINTEXT://{內網ip}:9092 將項目日志級別調制 ...

windows下使用kafka遇到這個問題: Error when sending message to topic test with key: null, value: 2 bytes with error ...

我的kafka是CDH上的2.11版本 在linux客戶端啟動了kafka自帶的producer 和consumer后能正常生產和消費 但是， 在idea啟動了自定義的生產者向kafka發送數據的時候報： 並且開啟消費者后看不到數據，說明生產者發送數據失敗 有人說： 修改 ...

今天居然碰到這個錯誤，參考以下解決方案： 修改server.properties，然后將每個節點的kafka重啟即可解決。 查看集群是否有broker沒有運行 ...

在做支付訂單寬表的場景，需要關聯的表比較多而且支付有可能要延遲很久，這種情況下不太適合使用Flink的表Join，想到的另外一種解決方案是消費多個Topic的數據，再根據訂單號進行keyBy,再在邏輯中根據不同Topic處理，所以在接收到的消息中最好能夠有topic字段 ...

項目名稱：布控預警 水平拆分出來的項目，作為一個單獨的可以對外提供服務的項目 項目設計：springcloud，可以集成各個不同平台的一個作為對外提供的微服務項目 項目功能：實現各個平台和本平台之間的布控（對人員和攝像頭進行和廠商對接可以進行實時抓拍）和預警（廠商抓拍到之后實時通知給本平台 ...

環境： Windows 10, Ubuntu 18.04 （虛擬機） Java 8 Spring Boot 2.5.2，其下的 spring-kafka 版本 2.7.3，kafka-streams 版本 2.7.1 apache-zookeeper-3.7.0，單機 ...

參照我之前的一篇博文Kafka學習之（二）Centos下安裝Kafka安裝了kafka並啟動，狀況並不像我之前最初的預期，報錯了，並且我在當前Linux環境下安裝的Java版本、Kafka版本都是和之前博文一樣的，第一感覺難道是因為Linux(Centos)的版本不一致？？？ 拋開猜測，直接 ...