From dev-return-105466-archive-asf-public=cust-asf.ponee.io@kafka.apache.org Wed Jul 3 03:39:03 2019 Return-Path: X-Original-To: archive-asf-public@cust-asf.ponee.io Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [207.244.88.153]) by mx-eu-01.ponee.io (Postfix) with SMTP id 74D9E18060E for ; Wed, 3 Jul 2019 05:39:03 +0200 (CEST) Received: (qmail 52793 invoked by uid 500); 3 Jul 2019 03:39:01 -0000 Mailing-List: contact dev-help@kafka.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@kafka.apache.org Delivered-To: mailing list dev@kafka.apache.org Received: (qmail 52777 invoked by uid 99); 3 Jul 2019 03:39:01 -0000 Received: from mailrelay1-us-west.apache.org (HELO mailrelay1-us-west.apache.org) (209.188.14.139) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 03 Jul 2019 03:39:01 +0000 Received: from jira-lw-us.apache.org (unknown [207.244.88.139]) by mailrelay1-us-west.apache.org (ASF Mail Server at mailrelay1-us-west.apache.org) with ESMTP id 9E364E2E81 for ; Wed, 3 Jul 2019 03:39:00 +0000 (UTC) Received: from jira-lw-us.apache.org (localhost [127.0.0.1]) by jira-lw-us.apache.org (ASF Mail Server at jira-lw-us.apache.org) with ESMTP id 646FA261D3 for ; Wed, 3 Jul 2019 03:39:00 +0000 (UTC) Date: Wed, 3 Jul 2019 03:39:00 +0000 (UTC) From: "CHARELS (JIRA)" To: dev@kafka.apache.org Message-ID: In-Reply-To: References: Subject: =?utf-8?Q?[jira]_[Created]_(KAFKA-8?= =?utf-8?Q?624)_=E8=BF=99?= =?utf-8?Q?=E8=BE=B9=E6=98=AF=E6=9C=8D=E5=8A=A1=E7=AB=AF=E7=9A=84k?= =?utf-8?Q?afka=EF=BC=8C=E7=89=88=E6=9C=AC=E6=98=AF_kafk?= =?utf-8?Q?a=5F2.11-1.0.0?= =?utf-8?Q?.2=EF=BC=8C=E5=BD=93=E5=AE=A2=E6=88=B7?= =?utf-8?Q?=E7=AB=AF=E5=90=91=E4=B8=BB=E9=A2=98=E5=8F=91=E9=80=81=E6=B6=88?= =?utf-8?Q?=E6=81=AF=E7=9A=84=E6=97=B6=E5=80=99=E6=8A=9B=E5=87=BA?= =?utf-8?Q?=E5=A6=82=E4=B8=8B=E5=BC=82=E5=B8=B8=EF=BC=8C=E5=AE=A2=E6=88=B7?= =?utf-8?Q?=E7=AB=AF=E8=B7=9F=E6=9C=8D=E5=8A=A1=E7=AB=AF=E7=9A=84?= =?utf-8?Q?=E7=89=88=E6=9C=AC=E4=B8=8D=E4=B8=80=E8=87=B4=E5=90=97=EF=BC=9F?= MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: quoted-printable X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 CHARELS created KAFKA-8624: ------------------------------ Summary: =E8=BF=99=E8=BE=B9=E6=98=AF=E6=9C=8D=E5=8A=A1=E7=AB= =AF=E7=9A=84kafka=EF=BC=8C=E7=89=88=E6=9C=AC=E6=98=AF kafka_2.11-1.0.0.2=EF= =BC=8C=E5=BD=93=E5=AE=A2=E6=88=B7=E7=AB=AF=E5=90=91=E4=B8=BB=E9=A2=98=E5=8F= =91=E9=80=81=E6=B6=88=E6=81=AF=E7=9A=84=E6=97=B6=E5=80=99=E6=8A=9B=E5=87=BA= =E5=A6=82=E4=B8=8B=E5=BC=82=E5=B8=B8=EF=BC=8C=E5=AE=A2=E6=88=B7=E7=AB=AF=E8= =B7=9F=E6=9C=8D=E5=8A=A1=E7=AB=AF=E7=9A=84=E7=89=88=E6=9C=AC=E4=B8=8D=E4=B8= =80=E8=87=B4=E5=90=97=EF=BC=9F Key: KAFKA-8624 URL: https://issues.apache.org/jira/browse/KAFKA-8624 Project: Kafka Issue Type: Bug Components: log Affects Versions: 1.0.0 Reporter: CHARELS ERROR [KafkaApi-1004] Error when handling request \{replica_id=3D-1,max_wai= t_time=3D10000,min_bytes=3D0,topics=3D[{topic=3DETE,partitions=3D[{partitio= n=3D3,fetch_offset=3D119224671,max_bytes=3D1048576}]}]} (kafka.server.Kafka= Apis) java.lang.IllegalArgumentException: Magic v0 does not support record header= s at org.apache.kafka.common.record.MemoryRecordsBuilder.appendWithOffset(Me= moryRecordsBuilder.java:403) at org.apache.kafka.common.record.MemoryRecordsBuilder.append(MemoryRecord= sBuilder.java:586) at org.apache.kafka.common.record.AbstractRecords.convertRecordBatch(Abstr= actRecords.java:134) at org.apache.kafka.common.record.AbstractRecords.downConvert(AbstractReco= rds.java:109) at org.apache.kafka.common.record.FileRecords.downConvert(FileRecords.java= :253) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$convertedPartit= ionData$1$1$$anonfun$apply$4.apply(KafkaApis.scala:519) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$convertedPartit= ionData$1$1$$anonfun$apply$4.apply(KafkaApis.scala:517) at scala.Option.map(Option.scala:146) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$convertedPartit= ionData$1$1.apply(KafkaApis.scala:517) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$convertedPartit= ionData$1$1.apply(KafkaApis.scala:507) at scala.Option.flatMap(Option.scala:171) at kafka.server.KafkaApis.kafka$server$KafkaApis$$convertedPartitionData$1= (KafkaApis.scala:507) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$createResponse$= 2$1.apply(KafkaApis.scala:555) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$createResponse$= 2$1.apply(KafkaApis.scala:554) at scala.collection.Iterator$class.foreach(Iterator.scala:891) at scala.collection.AbstractIterator.foreach(Iterator.scala:1334) at scala.collection.IterableLike$class.foreach(IterableLike.scala:72) at scala.collection.AbstractIterable.foreach(Iterable.scala:54) at kafka.server.KafkaApis.kafka$server$KafkaApis$$createResponse$2(KafkaAp= is.scala:554) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$fetchResponseCa= llback$1$1.apply(KafkaApis.scala:568) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$fetchResponseCa= llback$1$1.apply(KafkaApis.scala:568) at kafka.server.KafkaApis$$anonfun$sendResponseMaybeThrottle$1.apply$mcVI$= sp(KafkaApis.scala:2033) at kafka.server.ClientRequestQuotaManager.maybeRecordAndThrottle(ClientReq= uestQuotaManager.scala:54) at kafka.server.KafkaApis.sendResponseMaybeThrottle(KafkaApis.scala:2032) at kafka.server.KafkaApis.kafka$server$KafkaApis$$fetchResponseCallback$1(= KafkaApis.scala:568) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$processResponse= Callback$1$1.apply$mcVI$sp(KafkaApis.scala:587) at kafka.server.ClientQuotaManager.maybeRecordAndThrottle(ClientQuotaManag= er.scala:176) at kafka.server.KafkaApis.kafka$server$KafkaApis$$processResponseCallback$= 1(KafkaApis.scala:586) at kafka.server.KafkaApis$$anonfun$handleFetchRequest$3.apply(KafkaApis.sc= ala:603) at kafka.server.KafkaApis$$anonfun$handleFetchRequest$3.apply(KafkaApis.sc= ala:603) at kafka.server.ReplicaManager.fetchMessages(ReplicaManager.scala:820) at kafka.server.KafkaApis.handleFetchRequest(KafkaApis.scala:595) at kafka.server.KafkaApis.handle(KafkaApis.scala:99) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:65) at java.lang.Thread.run(Thread.java:748) -- This message was sent by Atlassian JIRA (v7.6.3#76005)