I have a hard time figuring out how to do a commit using API 0.8.2 on JDK 8.
I tried using the examples from 0.8.1.1. First of all: I can't use OffsetMetadataAndError inside the offsets-map as it was possible in 0.8.1. I can't really find a difference, but builds break. I'm also unable to figure out all of the required parameters. <topic> and <partition> are obviuous. I suppose the <groupId> is the client-name I picked for my consumer. But what is the value expected for the <correlationId>? Here is my code that won't build with 0.8.2 on JDK 8: Map<TopicAndPartition, OffsetAndMetadata> offsets = new HashMap<>(); offsets.put(new TopicAndPartition(*<topic>*, *<partition>*), new OffsetMetadataAndError(messageAndOffset.offset(), "", ErrorMapping.NoError())); OffsetCommitRequest ocRequest = new OffsetCommitRequest(*<groupId>*, offsets, *<correlationId>*, consumer.clientId(), kafka.api.OffsetCommitRequest.CurrentVersion()); OffsetCommitResponse offsetCommitResponse = consumer.commitOffsets(ocRequest); Thanks, Jochen -- Jochen Mader | Lead IT Consultant codecentric AG | Elsenheimerstr. 55a | 80687 München | Deutschland tel: +49 89 215486633 | fax: +49 89 215486699 | mobil: +49 152 51862390 www.codecentric.de | blog.codecentric.de | www.meettheexperts.de | www.more4fi.de Sitz der Gesellschaft: Düsseldorf | HRB 63043 | Amtsgericht Düsseldorf Vorstand: Michael Hochgürtel . Mirko Novakovic . Rainer Vehns Aufsichtsrat: Patric Fedlmeier (Vorsitzender) . Klaus Jäger . Jürgen Schütz
