org.apache.kafka.common.errors.TimeoutException: Срок действия истек 119 записей для TopicJAVA-0: 60030 мс прошло с момента создания пакета плюс время ожидания - PullRequest
Новая
       3

org.apache.kafka.common.errors.TimeoutException: Срок действия истек 119 записей для TopicJAVA-0: 60030 мс прошло с момента создания пакета плюс время ожидания

0 голосов
/ 30 ноября 2018

Вот мой код и зависимость. Я пытаюсь писать сообщения в KAfka с помощью API производителя.И тема также создается, хотя сообщения не отправляются в тему Kafka со следующим исключением

org.apache.kafka.common.errors.TimeoutException: срок истечения 119 записей для TopicJAVA-0:60049 мс прошло с момента создания партии плюс время ожидания. 

public static void main(String[] args) throws Exception {

     Map<String,Object> map=new HashMap<String, Object>();
        map.put("bootstrap.servers","10.1.7.82:6667");
        map.put("key.serializer","org.apache.kafka.common.serialization.StringSerializer");
        map.put("value.serializer","org.apache.kafka.common.serialization.StringSerializer");
        map.put("metadata.fetch.timeout.ms", "60000");
        map.put("request.timeout.ms", "60000");
        map.put("batch.size",16384);
        map.put("buffer.memory", 33554432);

    KafkaProducer<String, String> producer = new KafkaProducer<String, String>(map);
    // Write
        // create the topic message, enter topic name and message
        ProducerRecord<String, String> record = new ProducerRecord<String, String>("TopicJAVA", "msg from java");
        // function to push the message to kafka topic
        RecordMetadata meta=producer.send(record).get();
        System.out.println("Message Sent"+meta.partition());
        Thread.sleep(500);
        producer.close();

}

А вот моя зависимость POM

http://maven.apache.org/xsd/maven-4.0.0.xsd"> 4.0.0 

<groupId>com.gaurav.kafka</groupId>
<artifactId>kakfa-producer-consumer-example</artifactId>
<version>0.0.1-SNAPSHOT</version>
<packaging>jar</packaging>

<name>kakfa-producer-consumer-example</name>
<url>http://maven.apache.org</url>

<properties>
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>

<dependencies>
    <!-- https://mvnrepository.com/artifact/org.apache.kafka/kafka-clients -->
    <!-- <dependency>
        <groupId>org.apache.kafka</groupId>
        <artifactId>kafka-clients</artifactId>
        <version>1.1.0</version>
    </dependency> -->

    <!-- Ashok Kafka Dependencies -->


    <dependency>
        <groupId>org.slf4j</groupId>
        <artifactId>slf4j-log4j12</artifactId>
        <version>1.7.5</version>
    </dependency>
    <dependency>
        <groupId>org.apache.kafka</groupId>
        <artifactId>kafka_2.10</artifactId>
        <version>0.8.2.2</version>
    </dependency>
<dependency>
    <groupId>org.apache.kafka</groupId>
    <artifactId>kafka-clients</artifactId>
    <version>0.10.2.1</version>
</dependency>
    <dependency>
        <groupId>com.101tec</groupId>
        <artifactId>zkclient</artifactId>
        <version>0.7</version>
    </dependency>



    <!-- https://mvnrepository.com/artifact/com.fasterxml.jackson.core/jackson-databind -->
    <dependency>
        <groupId>com.fasterxml.jackson.core</groupId>
        <artifactId>jackson-databind</artifactId>
        <version>2.9.5</version>
    </dependency>


</dependencies>

Я не имею абсолютно никакого представления о том, чего здесь не хватает. Понимание этого было бы очень полезно. Наша версия kafka - 10.1.2.6.4.0-91. M пытается решить ее в течение последних 3 дней, но чувствует себя беспомощным

...