kafka.common.FailedToSendMessageException: Failed to send messages after 3 tries.

Google Groups | no jihun | 2 months ago
  1. 0

    kafka client 0.8 and confluent 3.0.1

    Google Groups | 2 months ago | no jihun
    kafka.common.FailedToSendMessageException: Failed to send messages after 3 tries.
  2. 0

    Can't connect to a remote Kafka producer from windows through java code

    Stack Overflow | 2 years ago | sbgowtham
    kafka.common.FailedToSendMessageException: Failed to send messages after 3 tries.
  3. 0

    Unable to push messages to apache kafka?

    Stack Overflow | 2 years ago | Piyush Kumar
    kafka.common.FailedToSendMessageException: Failed to send messages after 3 tries.
  4. Speed up your debug routine!

    Automated exception search integrated into your IDE

  5. 0

    Kafka: java client failed to send messages after x tries

    Stack Overflow | 1 year ago | Alban
    kafka.common.FailedToSendMessageException: Failed to send messages after 2 tries.
  6. 0

    Kafka Producer Code FailedToSendMessageException

    Stack Overflow | 1 year ago | chandra sekhar lagadapati
    kafka.common.FailedToSendMessageException: Failed to send messages after 3 tries.

    2 unregistered visitors
    Not finding the right solution?
    Take a tour to get the most out of Samebug.

    Tired of useless tips?

    Automated exception search integrated into your IDE

    Root Cause Analysis

    1. kafka.common.FailedToSendMessageException

      Failed to send messages after 3 tries.

      at kafka.producer.async.DefaultEventHandler.handle()
    2. Apache Kafka
      Producer.send
      1. kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:90)
      2. kafka.producer.Producer.send(Producer.scala:77)
      3. kafka.javaapi.producer.Producer.send(Producer.scala:33)
      3 frames
    3. us.band.stats
      BaKafkaProducerTest.baKafkaTest
      1. us.band.stats.scv.kafka.BaKafkaProducerTest.baKafkaTest(BaKafkaProducerTest.java:25)
      1 frame
    4. Java RT
      Method.invoke
      1. sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
      2. sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
      3. sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
      4. java.lang.reflect.Method.invoke(Method.java:497)
      4 frames
    5. JUnit
      ParentRunner.run
      1. org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:44)
      2. org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:15)
      3. org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:41)
      4. org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:20)
      5. org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:263)
      6. org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:69)
      7. org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:48)
      8. org.junit.runners.ParentRunner$3.run(ParentRunner.java:231)
      9. org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:60)
      10. org.junit.runners.ParentRunner.runChildren(ParentRunner.java:229)
      11. org.junit.runners.ParentRunner.access$000(ParentRunner.java:50)
      12. org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:222)
      13. org.junit.runners.ParentRunner.run(ParentRunner.java:292)
      13 frames
    6. JUnit4 Runner
      JUnit4TestReference.run
      1. org.eclipse.jdt.internal.junit4.runner.JUnit4TestReference.run(JUnit4TestReference.java:86)
      1 frame
    7. JUnit3 Runner
      RemoteTestRunner.main
      1. org.eclipse.jdt.internal.junit.runner.TestExecution.run(TestExecution.java:38)
      2. org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:459)
      3. org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:675)
      4. org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.run(RemoteTestRunner.java:382)
      5. org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.main(RemoteTestRunner.java:192)
      5 frames