[
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)
