8
Tôi đang sử dụng Kafka 0.8.2.1 và API nhà sản xuất mới. Máy chủ được thiết lập dưới dạng một nút trong mạng cục bộ.
Vấn đề là nhà sản xuất ném EOFException sau khi chạy một lúc (15 phút cuối cùng tôi đã kiểm tra), nhưng dường như không quan trọng vì nhà sản xuất của tôi tiếp tục làm việc sau này.nhà sản xuất kafka ném EOFException trong khi chạy
Con đường tôi khởi tạo sản xuất:
Map<String, Object> configs = new HashMap<>();
configs.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "192.168.1.101:9092");
configs.put(ProducerConfig.ACKS_CONFIG, "1");
configs.put(ProducerConfig.BLOCK_ON_BUFFER_FULL_CONFIG, "false");
configs.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());
configs.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());
this.producer = new KafkaProducer<>(configs);
Và ngoại trừ tôi nhận:
WARN [2015-06-17 02:07:28,896] org.apache.kafka.common.network.Selector: Error in I/O with /192.168.1.101
! java.io.EOFException: null
! at org.apache.kafka.common.network.NetworkReceive.readFrom(NetworkReceive.java:62) ~[kafka-clients-0.8.2.1.jar:na]
! at org.apache.kafka.common.network.Selector.poll(Selector.java:248) ~[kafka-clients-0.8.2.1.jar:na]
! at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192) [kafka-clients-0.8.2.1.jar:na]
! at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191) [kafka-clients-0.8.2.1.jar:na]
! at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122) [kafka-clients-0.8.2.1.jar:na]
! at java.lang.Thread.run(Thread.java:745) [na:1.8.0_45]
Mặc dù mã của tôi vẫn hoạt động với điều này, tôi muốn biết tại sao và làm thế nào để ngăn chặn nó.
Tôi có cùng một vấn đề bây giờ, bạn đã figured it out rồi sao? Có vẻ như có vấn đề chính thức https://issues.apache.org/jira/browse/KAFKA-2078 – shobull