apache pulsar : error while consuming message

Question

I am trying to consume from pulsar topic. My client code can be seen below. But, I am facing NoClassDefFoundError. Please let me know how to resolve this.

pulsar client version: 2.10, pulsar server version: 2.10, installation type: standalone(not docker), OS: Ubuntu 20.04.4 LTS

My pulsar client code:

private static void consumeFromPulsarAsync() throws Exception {

    logger.info("consumeFromPulsarAsync()");

    PulsarClient client = PulsarClient.
        builder()
        .serviceUrl("pulsar://localhost:6650")
        .build();

    logger.info("consumeFromPulsarAsync() client");

    Consumer consumer = client.newConsumer(Schema.STRING)
        .topic("persistent://public/default/ack-2")
        .consumerName("pulsar-consumer-id-" + Math.random())
        .subscriptionName("pulsar-subscription-id-" + Math.random())
        .subscriptionType(SubscriptionType.Shared).subscribe();

    logger.info("consumeFromPulsarAsync() consumer");

    consumer.receiveAsync().thenCompose((msg) -> {
      logger.info("consumeFromPulsarAsync() consumed msg :: {}", msg.getValue());
      try {
        consumer.acknowledge(msg);
      } catch (PulsarClientException e) {
        throw new RuntimeException(e);
      }
      return null;
    });
  }

My pom.xml



  4.0.0

  com.company
  my.work.manager
  release-1.0
  my Worker Manager

  
    1.8
    1.8
    1.14.3
    2.10.0
  

  
    
      org.apache.flink
      flink-clients_2.12
      ${flink.version}
    
    
      org.apache.flink
      flink-connector-kafka_2.12
      ${flink.version}
    
    
      org.apache.flink
      flink-connector-pulsar
      1.15.0
    
    
      com.google.code.gson
      gson
      2.8.9
    
    
      org.projectlombok
      lombok
      1.18.22
      provided
    
    
      org.json
      json
      20210307
    
    
      org.slf4j
      slf4j-api
      1.7.32
    
    
      org.slf4j
      slf4j-simple
      1.7.30
    
    
      org.yaml
      snakeyaml
      1.30
    
    
      org.apache.httpcomponents
      httpclient
      4.5.13
    
    
      org.apache.pulsar
      pulsar-client
      ${pulsar.version}
    
  

  
    
      
        maven-compiler-plugin
        3.8.1
        
          1.8
          1.8
          
            -Xlint:all,-options,-path
          
        
      

      
        org.apache.maven.plugins
        maven-jar-plugin
        2.5
        
          
            
              com.company.my.manager.flink.myWorkManager
            
          
        
      

      
        org.apache.maven.plugins
        maven-assembly-plugin
        3.3.0
        
          
            jar-with-dependencies
          
        
        
          
            make-assembly
            package
            
              single
            
          
        
      
    
    
      
        src/main/resources
        ${project.build.outputDirectory}
        
          **/*.yml

Error it is showing:

2022-05-10 17:52:52,549 WARN org.apache.pulsar.client.impl.MultiTopicsConsumerImpl [] - Encountered error in partition auto update timer task for multi-topic consumer. Another task will be scheduled. java.lang.NoClassDefFoundError: org/apache/pulsar/shade/com/google/common/primitives/Ints at org.apache.pulsar.shade.com.google.common.collect.Lists.computeArrayListCapacity(Lists.java:152) ~[e8fe35f4-c20c-4c3e-9b81-a3ff1a0ebaec_my.work.manager-release-1.0-jar-with-dependencies.jar:?] at org.apache.pulsar.shade.com.google.common.collect.Lists.newArrayListWithExpectedSize(Lists.java:192) ~[e8fe35f4-c20c-4c3e-9b81-a3ff1a0ebaec_my.work.manager-release-1.0-jar-with-dependencies.jar:?] at org.apache.pulsar.client.impl.MultiTopicsConsumerImpl$TopicsPartitionChangedListener.onTopicsExtended(MultiTopicsConsumerImpl.java:1238) ~[e8fe35f4-c20c-4c3e-9b81-a3ff1a0ebaec_my.work.manager-release-1.0-jar-with-dependencies.jar:?] at org.apache.pulsar.client.impl.MultiTopicsConsumerImpl$1.run(MultiTopicsConsumerImpl.java:1350) [e8fe35f4-c20c-4c3e-9b81-a3ff1a0ebaec_my.work.manager-release-1.0-jar-with-dependencies.jar:?] at org.apache.pulsar.shade.io.netty.util.HashedWheelTimer$HashedWheelTimeout.run(HashedWheelTimer.java:715) [e8fe35f4-c20c-4c3e-9b81-a3ff1a0ebaec_my.work.manager-release-1.0-jar-with-dependencies.jar:?] at org.apache.pulsar.shade.io.netty.util.concurrent.ImmediateExecutor.execute(ImmediateExecutor.java:34) [e8fe35f4-c20c-4c3e-9b81-a3ff1a0ebaec_my.work.manager-release-1.0-jar-with-dependencies.jar:?] at org.apache.pulsar.shade.io.netty.util.HashedWheelTimer$HashedWheelTimeout.expire(HashedWheelTimer.java:703) [e8fe35f4-c20c-4c3e-9b81-a3ff1a0ebaec_my.work.manager-release-1.0-jar-with-dependencies.jar:?] at org.apache.pulsar.shade.io.netty.util.HashedWheelTimer$HashedWheelBucket.expireTimeouts(HashedWheelTimer.java:790) [e8fe35f4-c20c-4c3e-9b81-a3ff1a0ebaec_my.work.manager-release-1.0-jar-with-dependencies.jar:?] at org.apache.pulsar.shade.io.netty.util.HashedWheelTimer$Worker.run(HashedWheelTimer.java:503) [e8fe35f4-c20c-4c3e-9b81-a3ff1a0ebaec_my.work.manager-release-1.0-jar-with-dependencies.jar:?] at org.apache.pulsar.shade.io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) [e8fe35f4-c20c-4c3e-9b81-a3ff1a0ebaec_my.work.manager-release-1.0-jar-with-dependencies.jar:?] at java.lang.Thread.run(Thread.java:829) [?:?]

apache pulsar : error while consuming message

Answers (1)

Related Questions