what is package of uploaded java class

[git-josip]

Ask a question

When I upload example.

Kafka custom partitioner:

import org.apache.kafka.clients.producer.Partitioner;
import org.apache.kafka.common.Cluster;

import java.util.Map;

public class ByKeyPartitioner implements Partitioner {

    @Override
    public int partition(String topic, Object key, byte[] keyBytes, Object value, byte[] valueBytes, Cluster cluster) {
        int partitionKeyAsString = (String) key;
        Integer keyInt = new Integer(partitionKeyAsString);
        return keyInt % 20;
    }

    @Override
    public void close() {

    }

    @Override
    public void configure(Map<String, ?> configs) {

    }
}

what is package of this class?

Ass I need to reference it in camel kafka component by class.

I tried many different approaches but I can not get it work, I am getting error there is no class.
org.apache.kafka.common.config.ConfigException: Invalid value ByKeyPartitioner for configuration partitioner.class: Class ByKeyPartitioner could not be found

What is the package of upldoaded file, as I need to provide it obviously ?

Variant

None

Container Management (if applicable)

None

Operating System (if applicable)

None

Version

None

[mgubaidullin]

I believe that package should be related to your camel.jbang.gav property in application.properties

[davsclaus]

this code is wrong

  int partitionKeyAsString = (String) key;

/ByKeyPartitioner.java:10: error: incompatible types: java.lang.String cannot be converted to int
int partitionKeyAsString = (String) key;

[davsclaus]

This can run

Put in application.properties

camel.jbang.dependencies=camel-kafka

And fix that compilation error in your java code

Here is yaml-dsl that runs for me

- route:
    id: route-2842
    nodePrefixId: route-05e
    from:
      id: from-71ad
      uri: timer
      parameters:
        timerName: trigger
      steps:
        - to:
            id: to-9242
            uri: kafka
            parameters:
              topic: cheese
              partitioner: ByKeyPartitioner
              brokers: localhost:1234

[davsclaus]

You can also add in top of your java source, instead of setting dependency in application.properties

//DEPS camel-kafka
import org.apache.kafka.clients.producer.Partitioner;
import org.apache.kafka.common.Cluster;