Hi, folks,
I found that the Mirror Maker docs should be updated(KAFKA-2449) since it
mentions N source to 1 destination will not be supported. So is that true
it only support 1 source to 1 destination in 0.9.0? Or it will be extended
to support N source to N dest?
Thanks,
Samuel
2452, which will
> enable SSL on the consumer side too.
>
> Thanks,
>
> Jun
>
> On Fri, Aug 28, 2015 at 12:01 PM, Xiang Zhou (Samuel)
> wrote:
>
> > Hi, folks,
> >
> > I just want to check if anybody know if there are any plan of Kafka
> > Mirro
Hi, folks,
I just want to check if anybody know if there are any plan of Kafka
MirrorMaker support running over SSL. I tried to follow
https://cwiki.apache.org/confluence/display/KAFKA/Deploying+SSL+for+Kafka
to configure consumer/producer properties with SSL but no luck, looks that
Kafka MirrorMa
Chintalapani (ka...@harsha.io)
> wrote:
>
> Hi Xiang,
> Did you try following the instructions here
> https://cwiki.apache.org/confluence/display/KAFKA/Deploying+SSL+for+Kafka
> .
> Whats the output of openssl s_client and which version of java and OS are
> you using.
>
>
Hi, folks,
I am just following up to see if anybody has clue on the following issue
when I was following the guidelines provided in the step of running openssl
to verify the SSL setup:
[2015-08-25 22:29:15,385] WARN Error in I/O with connection to X
(org.apache.kafka.common.network.Selector)
on the same version can be set to
version number 1 !!). So updating kafka jar 0.8.2.1 solved the problem.
On Mon, Jun 29, 2015 at 11:10 AM, Xiang Zhou (Samuel)
wrote:
> Thank you for your response Noah. I just tried with the same groupId and
> group name when I committed the offset, it sti
our consumer group id. You must've picked a value
> to commit with, so it needs to be the same one.
>
> On Mon, Jun 29, 2015 at 12:50 AM Xiang Zhou (Samuel)
> wrote:
>
> > Hi,
> >
> > I use the following snippets to try to get fetch the offset in a
> > Simp
Hi,
I use the following snippets to try to get fetch the offset in a
SimpleConsumer I have committed (the commission has created topic
__consumer_offsets):
fetchRequest = new OffsetFetchRequest(
clientGroup, // What's the client group for simple consumer?
partitions,
(short) 1 /* version
