public int partition()

in kafka/src/main/java/org/apache/camel/example/kafka/StringPartitioner.java [36:48]

• 9 lines of code
• 2 McCabe index (conditional complexity)

    public int partition(String topic, Object key, byte[] keyBytes, Object value, byte[] valueBytes, Cluster cluster) {
        int partId = 0;

        if (key instanceof String) {
            String sKey = (String) key;
            int len = sKey.length();

            // This will return either 1 or zero
            partId = len % 2;
        }

        return partId;
    }