1.如何啟動kafka？
2.如何通過**實現生產者例子 ？
3.如何通過**實現消費者例子？
1.啟動kafka。
//啟動zookeeper server (用&是為了能退出命令列)：
bin/zookeeper-server-start.sh config/zookeeper.properties &
//啟動kafka server:
bin/kafka-server-start.sh config/server.properties &
2.新建乙個生產者例子
import j**a.util.properties;
import kafka.j**aapi.producer.producer;
import kafka.producer.keyedmessage;
import kafka.producer.producerconfig;
public class kafkatest
}3.新建乙個消費者例子
import j**a.nio.bytebuffer;
import j**a.util.hashmap;
import j**a.util.list;
import j**a.util.map;
import j**a.util.properties;
import j**a.util.concurrent.executorservice;
import j**a.util.concurrent.executors;
import kafka.consumer.consumer;
import kafka.consumer.consumerconfig;
import kafka.consumer.kafkastream;
import kafka.j**aapi.consumer.consumerconnector;
import kafka.message.message;
import kafka.message.messageandmetadata;
public class consumersample
} });
} } }
最簡潔的中斷現場保護
閱讀韋老師的中斷現場保護和恢復 感覺下面紅色部分的 似乎用不到，因為恢復現場的時候，lr的內容早就放在堆疊裡面，並且要推送到pc了，我把下面 的紅色部分去掉，做實驗，可以順利進出中斷，可見這幾句話對中斷現場的保護和恢復沒起到作用的，修改後的 我用藍色字型標出，是保護現場需要的最小系統。順便提一下，a...
最簡潔的堆排序實現
public class sort heapsort arr for int i 0 i arr.length i public static void heapdown int array,int parent,int length array parent temp public static ...
最簡潔的CSS清除浮動的方法
清理浮動有很多種方式，像使用 br 標籤自帶的 clear 屬，使用元素的 overflow，使用空標籤來設定 clear both 等等。但考慮到相容問題和語義化的問題，一般我們都會使用如下 來清理浮動。複製 如下 清理浮動 clearfix after clearfix 其原理是，在 高階 瀏覽...