Hi, I need to create a single partition from a single topic in Kafka. I am doing this because the order of messages coming from my Kafka producer is very important to me (if I tried to have multiple partition with multiple threads doing I/O, my ordering of messages is not guaranteed; at least this is what i have read). But I do have multiple consumers consuming the same message streams (strictly in the order that the producer produced them). Now, since, I am going to have only one thread per consumer in Kafka, I would like to think that I don't have to write the following code:
Map<String, Integer> topicCountMap = new HashMap<String, Integer>(); topicCountMap.put(topic, new Integer(a_numThreads)); Map<String, List<KafkaStream<byte[], byte[]>>> consumerMap = consumer.createMessageStreams(topicCountMap); I need to create message streams without passing topic count map. I just know that I got a solitary topic and a single thread. I dont want to create a hashmap of topics and threads. If you can suggest me the best way to deal with this, would appreciate a lot. Thanks, Pradeep.
