Producer cannot receive new topic

[adyliu]

Producer sends some messages with new topic(not registed at broker).

The producer processes the partitions changing incorrectly if the broker creates this topic more than one partition.

See the code(https://github.com/adyliu/jafka/blob/v1.0/src/main/java/com/sohu/jafka/producer/ZKBrokerPartitionInfo.java):

class BrokerTopicsListener implements IZkChildListener {

    private Map<String, SortedSet<Partition>> originalBrokerTopicsParitions;

    private Map<Integer, Broker> originBrokerIds;

    public BrokerTopicsListener(Map<String, SortedSet<Partition>> originalBrokerTopicsParitions, Map<Integer, Broker> originBrokerIds) {
        super();
        this.originalBrokerTopicsParitions = originalBrokerTopicsParitions;
        this.originBrokerIds = originBrokerIds;

We need a new map before the producer creating a default partition for new topic.

    public BrokerTopicsListener(Map<String, SortedSet<Partition>> originalBrokerTopicsParitions,
            Map<Integer, Broker> originBrokerIds) {
        super();
        this.originalBrokerTopicsParitions = new HashMap<String, SortedSet<Partition>>(
                originalBrokerTopicsParitions);
        this.originBrokerIds = new HashMap<Integer, Broker>(originBrokerIds);

[adyliu]

Fixed at 1.1: 4cf4b0d