Can you add yourself as a watcher on KAFKA-1729? I will update that when I fix the example on the wiki.
On Sun, Feb 22, 2015 at 10:16:44PM +0100, Jochen Mader wrote: > 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
