Error reading field 'throttle_time_ms': java.nio.BufferUnderflowException
1276 단어 kafka
04 Jul 2018 20:43:44,401 ERROR [kafka-producer-network-thread | producer-1] (org.apache.kafka.clients.producer.internals.Sender.run:130) - Uncaught error in kafka producer I/O thread:
org.apache.kafka.common.protocol.types.SchemaException: Error reading field 'throttle_time_ms': java.nio.BufferUnderflowException
at org.apache.kafka.common.protocol.types.Schema.read(Schema.java:71)
at org.apache.kafka.clients.NetworkClient.handleCompletedReceives(NetworkClient.java:439)
at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:265)
at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:216)
at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:128)
at java.lang.Thread.run(Thread.java:748)flume 버전이 1.7이고 kafka 버전이 0.8로 오래되어 호환되지 않기 때문에 kafka 버전을 0.11 또는 flume 버전으로 업그레이드하여 1.6로 해결합니다!
주:flume1.6 및 이전 버전에는 Taildir(org.apache.flume.source.taildir.Taildir.TaildirSource)라는 소스 type이 없습니다. 이 형식은 디렉터리 변화를 지원하는 파일입니다. 단점 리셋을 지원합니다. 1.6 버전에서 이 기능을 사용하려면 1.7 버전의 Taildir Source 구성 요소 원본을 컴파일하여 포장한 후,Flume1.6 설치 디렉터리의lib 파일 디렉터리에 넣어야 합니다.
TaildirSource 구성 요소를 사용하려면 Flume 구성 파일에 전체 클래스 이름을 지정합니다.
a1.sources.r1.type = com.xxx.flume.source.TaildirSource
이 내용에 흥미가 있습니까?
현재 기사가 여러분의 문제를 해결하지 못하는 경우 AI 엔진은 머신러닝 분석(스마트 모델이 방금 만들어져 부정확한 경우가 있을 수 있음)을 통해 가장 유사한 기사를 추천합니다:
Spring Cloud를 사용한 기능적 Kafka - 1부지금까지 찾을 수 없었던 Spring Cloud Kafka의 작업 데모를 만들기 위해 이 기사를 정리했습니다. Confluent 스키마 레지스트리 7.1.0 이 기사는 먼저 Spring Cloud Stream을 사용...
텍스트를 자유롭게 공유하거나 복사할 수 있습니다.하지만 이 문서의 URL은 참조 URL로 남겨 두십시오.
CC BY-SA 2.5, CC BY-SA 3.0 및 CC BY-SA 4.0에 따라 라이센스가 부여됩니다.
좋은 웹페이지 즐겨찾기
