[jira] [Resolved] (KAFKA-4268) huge server.logs during the error frequently happen "Message format version for partition 200 not found"

["Ismael Juma (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/KAFKA-4268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Ismael Juma resolved KAFKA-4268.
--------------------------------
    Resolution: Duplicate

Marking as a duplicate of KAFKA-4362 even though this was filed first as KAFKA-4362 has more information and a PR has been submitted.

> huge server.logs during the error frequently happen "Message format version for partition 200 not found" 
> ---------------------------------------------------------------------------------------------------------
>
>                 Key: KAFKA-4268
>                 URL: https://issues.apache.org/jira/browse/KAFKA-4268
>             Project: Kafka
>          Issue Type: Bug
>          Components: core
>    Affects Versions: 0.10.0.1
>         Environment: Ubuntu 14.04.2 LTS
>            Reporter: Peyton Peng
>
> We have three broker running on three different ubuntu servers, there are about more than 200 topics served for different type of data. Each topic have 3 partitions. While I added a new consumer with the group "wlas" on two different machine(centos), which is running within flume, to subscribe all above topics in one consumer, after a while, we got the exception as below, the exception throws in server.log, and loops frequently, which cause the disk space leak.
> I doubt if the issue related with "one consumer subscribe so many topics", and running on two machine.
> (even got this exception, the topic data consume logic is running well)
> -------------- exception segment:
> [2016-10-07 08:49:27,982] INFO [GroupCoordinator 1]: Assignment received from leader for group wlas for generation 10 (kafka.coordinator.GroupCoordinator)
> [2016-10-07 08:49:27,982] ERROR [KafkaApi-1] Error when handling request {group_id=wlas,generation_id=10,member_id=flume-1011-6ec8e841-9fa8-4014-97b8-211b2ee2465e,group_assignment=[{member_id=flume-1011-6ec8e841-9fa8-4014-97b8-211b2ee2465e,member_assignment=java.nio.HeapByteBuffer[pos=0 lim=2301 cap=5023]},{member_id=flume-1009-7f6eacb5-8885-4131-8286-3848ed17b2a9,member_assignment=java.nio.HeapByteBuffer[pos=0 lim=2669 cap=2669]}]} (kafka.server.KafkaApis)
> java.lang.IllegalArgumentException: Message format version for partition 200 not found
>    at kafka.coordinator.GroupMetadataManager$$anonfun$14.apply(GroupMetadataManager.scala:633)
>    at kafka.coordinator.GroupMetadataManager$$anonfun$14.apply(GroupMetadataManager.scala:633)
>    at scala.Option.getOrElse(Option.scala:121)
>    at kafka.coordinator.GroupMetadataManager.kafka$coordinator$GroupMetadataManager$$getMessageFormatVersionAndTimestamp(GroupMetadataManager.scala:632)
>    at kafka.coordinator.GroupMetadataManager.prepareStoreGroup(GroupMetadataManager.scala:171)
>    at kafka.coordinator.GroupCoordinator.doSyncGroup(GroupCoordinator.scala:276)
>    at kafka.coordinator.GroupCoordinator.handleSyncGroup(GroupCoordinator.scala:240)
>    at kafka.server.KafkaApis.handleSyncGroupRequest(KafkaApis.scala:933)
>    at kafka.server.KafkaApis.handle(KafkaApis.scala:90)
>    at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:60)
>    at java.lang.Thread.run(Thread.java:745) 



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)