You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@flink.apache.org by naga sudhakar <na...@gmail.com> on 2023/04/20 16:55:43 UTC

Moving from flinkkafkaconsumer to kafkasource issues

Hi Team,
Greetings of the day..
we are on flink 1.16.1 version and using flinkkafkaconsumer today.
When I replaced it with kafkasource,it's failing with not able to connect
with kafka jaas configuration. Error says Kafka client entry not found in
/tmp/jass config file. We are passing the flonk runtime arg for the
security.auth.login conf details.  Same was working g with flink Kafka
consumer without any issues.
Did anyone  face this issue? Any suggestion? One of the stack over flow
suggestion was to have the content  of jaas config into java code,but not
use full



Thanks,
Nagasudhakar

Re: Moving from flinkkafkaconsumer to kafkasource issues

Posted by naga sudhakar <na...@gmail.com>.

Have applied all these into a Properties object and setusing set properties
method. Same properties was being used earlier for flinkkafkaconsumer which
was working fine.
Pfa the stacktrace as well.

Thanks,
Nagasudhakar.

On Fri, 21 Apr, 2023, 2:57 pm Martijn Visser, <ma...@apache.org>
wrote:

> Hi,
>
> Have you followed the documentation at
> https://nightlies.apache.org/flink/flink-docs-master/docs/connectors/datastream/kafka/#security
> ?
>
> Best regards,
>
> Martijn
>
> On Fri, Apr 21, 2023 at 3:00 AM Shammon FY <zj...@gmail.com> wrote:
>
>> Hi Naga
>>
>> Could you provide detailed error information? I think it may be useful
>> for positioning the issue
>>
>> Best,
>> Shammon FY
>>
>>
>> On Fri, Apr 21, 2023 at 12:56 AM naga sudhakar <na...@gmail.com>
>> wrote:
>>
>>> Hi Team,
>>> Greetings of the day..
>>> we are on flink 1.16.1 version and using flinkkafkaconsumer today.
>>> When I replaced it with kafkasource,it's failing with not able to
>>> connect with kafka jaas configuration. Error says Kafka client entry not
>>> found in /tmp/jass config file. We are passing the flonk runtime arg for
>>> the security.auth.login conf details.  Same was working g with flink Kafka
>>> consumer without any issues.
>>> Did anyone  face this issue? Any suggestion? One of the stack over flow
>>> suggestion was to have the content  of jaas config into java code,but not
>>> use full
>>>
>>>
>>>
>>> Thanks,
>>> Nagasudhakar
>>>
>>

Re: Moving from flinkkafkaconsumer to kafkasource issues

Posted by Martijn Visser <ma...@apache.org>.

Hi,

Have you followed the documentation at
https://nightlies.apache.org/flink/flink-docs-master/docs/connectors/datastream/kafka/#security
?

Best regards,

Martijn

On Fri, Apr 21, 2023 at 3:00 AM Shammon FY <zj...@gmail.com> wrote:

> Hi Naga
>
> Could you provide detailed error information? I think it may be useful for
> positioning the issue
>
> Best,
> Shammon FY
>
>
> On Fri, Apr 21, 2023 at 12:56 AM naga sudhakar <na...@gmail.com>
> wrote:
>
>> Hi Team,
>> Greetings of the day..
>> we are on flink 1.16.1 version and using flinkkafkaconsumer today.
>> When I replaced it with kafkasource,it's failing with not able to connect
>> with kafka jaas configuration. Error says Kafka client entry not found in
>> /tmp/jass config file. We are passing the flonk runtime arg for the
>> security.auth.login conf details.  Same was working g with flink Kafka
>> consumer without any issues.
>> Did anyone  face this issue? Any suggestion? One of the stack over flow
>> suggestion was to have the content  of jaas config into java code,but not
>> use full
>>
>>
>>
>> Thanks,
>> Nagasudhakar
>>
>

Re: Moving from flinkkafkaconsumer to kafkasource issues

Posted by Shammon FY <zj...@gmail.com>.

Hi Naga

Could you provide detailed error information? I think it may be useful for
positioning the issue

Best,
Shammon FY


On Fri, Apr 21, 2023 at 12:56 AM naga sudhakar <na...@gmail.com>
wrote:

> Hi Team,
> Greetings of the day..
> we are on flink 1.16.1 version and using flinkkafkaconsumer today.
> When I replaced it with kafkasource,it's failing with not able to connect
> with kafka jaas configuration. Error says Kafka client entry not found in
> /tmp/jass config file. We are passing the flonk runtime arg for the
> security.auth.login conf details.  Same was working g with flink Kafka
> consumer without any issues.
> Did anyone  face this issue? Any suggestion? One of the stack over flow
> suggestion was to have the content  of jaas config into java code,but not
> use full
>
>
>
> Thanks,
> Nagasudhakar
>