From dev-return-105505-archive-asf-public=cust-asf.ponee.io@kafka.apache.org Fri Jul 5 03:19:10 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 CFC68180595 for ; Fri, 5 Jul 2019 05:19:09 +0200 (CEST) Received: (qmail 7422 invoked by uid 500); 5 Jul 2019 03:19:02 -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 7395 invoked by uid 99); 5 Jul 2019 03:19: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; Fri, 05 Jul 2019 03:19: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 85826E0220 for ; Fri, 5 Jul 2019 03:19: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 4564626298 for ; Fri, 5 Jul 2019 03:19:00 +0000 (UTC) Date: Fri, 5 Jul 2019 03:19:00 +0000 (UTC) From: "CHARELS (JIRA)" To: dev@kafka.apache.org Message-ID: In-Reply-To: References: Subject: =?utf-8?Q?[jira]_[Resolved]_(KAFKA-?= =?utf-8?Q?8624)_?= =?utf-8?Q?=E8=BF=99=E8=BE=B9=E6=98=AF=E6=9C=8D=E5=8A=A1=E7=AB=AF=E7=9A=84?= =?utf-8?Q?kafka=EF=BC=8C=E7=89=88=E6=9C=AC=E6=98=AF_kaf?= =?utf-8?Q?ka=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 [ https://issues.apache.org/jira/browse/KAFKA-8624?page=3Dcom.atlassia= n.jira.plugin.system.issuetabpanels:all-tabpanel ] CHARELS resolved KAFKA-8624. ---------------------------- Resolution: Fixed Fix Version/s: 1.1.0 =E5=8F=AF=E8=83=BD=E6=98=AFproduer=E5=8D=87=E7=BA=A7=E4=BA=86client=E7=89= =88=E6=9C=AC=EF=BC=8C=E5=AF=BC=E8=87=B4kafka=E7=9A=84=E6=9C=8D=E5=8A=A1=E7= =AB=AF=E6=B6=88=E6=81=AF=E5=BD=A2=E6=88=90=E4=BA=86header=E4=B8=8D=E4=B8=80= =E8=87=B4=E4=BA=86=EF=BC=8C=E7=84=B6=E5=90=8E0.10.*=E7=89=88=E6=9C=AC=E7=9A= =84consumer=E6=97=A0=E6=B3=95=E6=B6=88=E8=B4=B9=EF=BC=8C=E6=8D=A2=E6=88=901= .1.0=E7=89=88=E6=9C=AC=E5=8F=AF=E6=AD=A3=E5=B8=B8=E6=B6=88=E8=B4=B9=E3=80= =82 > =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 > Priority: Major > Labels: pull-request-available > Fix For: 1.1.0 > > Attachments: image-2019-07-04-00-18-15-781.png, image-2019-07-04-= 14-49-47-802.png, image-2019-07-04-14-56-24-216.png, =E6=9D=8E=E5=BF=97=E6= =B6=9B.jpg > > Original Estimate: 12h > Remaining Estimate: 12h > > ERROR [KafkaApi-1004] Error when handling request \{replica_id=3D-1,max_w= ait_time=3D10000,min_bytes=3D0,topics=3D[{topic=3DETE,partitions=3D[{partit= ion=3D3,fetch_offset=3D119224671,max_bytes=3D1048576}]}]} (kafka.server.Kaf= kaApis) > java.lang.IllegalArgumentException: Magic v0 does not support record head= ers > at org.apache.kafka.common.record.MemoryRecordsBuilder.appendWithOffset(= MemoryRecordsBuilder.java:403) > at org.apache.kafka.common.record.MemoryRecordsBuilder.append(MemoryReco= rdsBuilder.java:586) > at org.apache.kafka.common.record.AbstractRecords.convertRecordBatch(Abs= tractRecords.java:134) > at org.apache.kafka.common.record.AbstractRecords.downConvert(AbstractRe= cords.java:109) > at org.apache.kafka.common.record.FileRecords.downConvert(FileRecords.ja= va:253) > at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$convertedPart= itionData$1$1$$anonfun$apply$4.apply(KafkaApis.scala:519) > at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$convertedPart= itionData$1$1$$anonfun$apply$4.apply(KafkaApis.scala:517) > at scala.Option.map(Option.scala:146) > at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$convertedPart= itionData$1$1.apply(KafkaApis.scala:517) > at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$convertedPart= itionData$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$$createRespons= e$2$1.apply(KafkaApis.scala:555) > at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$createRespons= e$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(Kafka= Apis.scala:554) > at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$fetchResponse= Callback$1$1.apply(KafkaApis.scala:568) > at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$fetchResponse= Callback$1$1.apply(KafkaApis.scala:568) > at kafka.server.KafkaApis$$anonfun$sendResponseMaybeThrottle$1.apply$mcV= I$sp(KafkaApis.scala:2033) > at kafka.server.ClientRequestQuotaManager.maybeRecordAndThrottle(ClientR= equestQuotaManager.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$$processRespon= seCallback$1$1.apply$mcVI$sp(KafkaApis.scala:587) > at kafka.server.ClientQuotaManager.maybeRecordAndThrottle(ClientQuotaMan= ager.scala:176) > at kafka.server.KafkaApis.kafka$server$KafkaApis$$processResponseCallbac= k$1(KafkaApis.scala:586) > at kafka.server.KafkaApis$$anonfun$handleFetchRequest$3.apply(KafkaApis.= scala:603) > at kafka.server.KafkaApis$$anonfun$handleFetchRequest$3.apply(KafkaApis.= scala: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)