Mailing-List: contact user-help@flink.apache.org; run by ezmlm
Precedence: bulk
From: "Tzu-Li (Gordon) Tai" <tzulitai@gmail.com>
In-Reply-To: <AM5PR0502MB2898C388735CD39372AE4747A2000@AM5PR0502MB2898.eurprd05.prod.outlook.com>
References: <AM5PR0502MB2898C388735CD39372AE4747A2000@AM5PR0502MB2898.eurprd05.prod.outlook.com>
MIME-Version: 1.0
Date: Tue, 11 Apr 2017 15:26:55 -0700
Message-ID: <CAJnSTVyi_9eVq+y9aD9Fa=W58V2ctNo3qXSwssUKC1oAHdaN2w@mail.gmail.com>
Subject: Re: Problems with Kerberos Kafka connection in version 1.2.0
To: user@flink.apache.org
Content-Type: multipart/alternative; boundary=f40304387f4ce9fdcb054ceb965f
archived-at: Tue, 11 Apr 2017 22:27:03 -0000

--f40304387f4ce9fdcb054ceb965f
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: quoted-printable

Hi Diego,

I think the problem is here:

security.kerberos.login.contexts: Client, KafkaClient

The space between =E2=80=9CClient,=E2=80=9D and =E2=80=9CKafkaClient=E2=80=
=9D is causing the problem.
Removing it should fix your issue.
Cheers,
Gordon

On April 11, 2017 at 3:24:20 AM, Diego Fustes Villad=C3=B3niga (dfustes@oes=
ia.com)
wrote:

Hi all,


I=E2=80=99m trying to connect to a kerberized Kafka cluster from Flink 1.2.=
0. I=E2=80=99ve
configured Flink correctly following instructions to get the credentials
from a given keytab. Here is the configuration:


security.kerberos.login.keytab: /home/biguardian/biguardian.keytab

security.kerberos.login.principal: biguardian

security.kerberos.login.use-ticket-cache: false

security.kerberos.login.contexts: Client, KafkaClient


However, I get this error:


org.apache.kafka.common.KafkaException: java.lang.IllegalArgumentException:
Could not find a 'KafkaClient' entry in `/tmp/jaas-522055201249067191.conf`


Indeed, the JAAS file is empty.


Do yon know what may be happening?


Diego Fustes Villad=C3=B3niga, Arquitecto Big Data, CCIM

--f40304387f4ce9fdcb054ceb965f
Content-Type: text/html; charset=UTF-8
Content-Transfer-Encoding: quoted-printable

<html><head><style>body{font-family:Helvetica,Arial;font-size:13px}</style>=
</head><body style=3D"word-wrap:break-word"><div id=3D"bloop_customfont" st=
yle=3D"font-family:Helvetica,Arial;font-size:13px;color:rgba(0,0,0,1.0);mar=
gin:0px;line-height:auto">Hi Diego,</div><div id=3D"bloop_customfont" style=
=3D"font-family:Helvetica,Arial;font-size:13px;color:rgba(0,0,0,1.0);margin=
:0px;line-height:auto"><br></div><div id=3D"bloop_customfont" style=3D"font=
-family:Helvetica,Arial;font-size:13px;color:rgba(0,0,0,1.0);margin:0px;lin=
e-height:auto">I think the problem is here:</div><div id=3D"bloop_customfon=
t" style=3D"font-family:Helvetica,Arial;font-size:13px;color:rgba(0,0,0,1.0=
);margin:0px;line-height:auto"><div><blockquote type=3D"cite" class=3D"clea=
n_bq" style=3D"font-family:Helvetica,Arial;font-size:13px;font-style:normal=
;font-variant:normal;font-weight:normal;letter-spacing:normal;line-height:n=
ormal;text-align:start;text-indent:0px;text-transform:none;white-space:norm=
al;word-spacing:0px"><div lang=3D"ES" link=3D"#0563C1" vlink=3D"#954F72"><d=
iv class=3D"WordSection1"><p class=3D"MsoNormal">security.kerberos.login.co=
ntexts: Client, KafkaClient</p></div></div></blockquote></div><p>The space =
between =E2=80=9CClient,=E2=80=9D and =E2=80=9CKafkaClient=E2=80=9D is caus=
ing the problem. Removing it should fix your issue.</p></div> Cheers,<div>G=
ordon<br> <div id=3D"bloop_sign_1491949426416388864" class=3D"bloop_sign"><=
/div> <br><p class=3D"airmail_on">On April 11, 2017 at 3:24:20 AM, Diego Fu=
stes Villad=C3=B3niga (<a href=3D"mailto:dfustes@oesia.com">dfustes@oesia.c=
om</a>) wrote:</p> <blockquote type=3D"cite" class=3D"clean_bq"><span><div =
lang=3D"ES" link=3D"#0563C1" vlink=3D"#954F72"><div></div><div>


<div class=3D"WordSection1">
<p class=3D"MsoNormal">Hi all,</p>
<p class=3D"MsoNormal">=C2=A0</p>
<p class=3D"MsoNormal">I=E2=80=99m trying to connect to a kerberized Kafka =
cluster from Flink 1.2.0. I=E2=80=99ve configured Flink correctly following=
 instructions to get the credentials from a given keytab. Here is the confi=
guration:</p>
<p class=3D"MsoNormal">=C2=A0</p>
<p class=3D"MsoNormal">=C2=A0</p>
<p class=3D"MsoNormal">security.kerberos.login.keytab: /home/biguardian/big=
uardian.keytab</p>
<p class=3D"MsoNormal">security.kerberos.login.principal: biguardian</p>
<p class=3D"MsoNormal">security.kerberos.login.use-ticket-cache: false</p>
<p class=3D"MsoNormal">security.kerberos.login.contexts: Client, KafkaClien=
t</p>
<p class=3D"MsoNormal">=C2=A0</p>
<p class=3D"MsoNormal">=C2=A0</p>
<p class=3D"MsoNormal">However, I get this error:</p>
<p class=3D"MsoNormal">=C2=A0</p>
<p class=3D"MsoNormal"><span style=3D"font-size:9.5pt;font-family:Consolas;=
color:black;background:#f0f7ff">org.apache.kafka.common.KafkaException: jav=
a.lang.IllegalArgumentException: Could not find a &#39;KafkaClient&#39; ent=
ry in `/tmp/jaas-522055201249067191.conf`</span></p>
<p class=3D"MsoNormal"><span style=3D"font-size:9.5pt;font-family:Consolas;=
color:black;background:#f0f7ff">=C2=A0</span></p>
<p class=3D"MsoNormal">Indeed, the JAAS file is empty.</p>
<p class=3D"MsoNormal">=C2=A0</p>
<p class=3D"MsoNormal">Do yon know what may be happening?</p>
<p class=3D"MsoNormal">=C2=A0</p>
<p class=3D"MsoNormal"><span style=3D"mso-fareast-language:ES">Diego Fustes=
 Villad=C3=B3niga, Arquitecto Big Data, CCIM</span></p>
<p class=3D"MsoNormal">=C2=A0</p>
</div>


</div></div></span></blockquote></div></body></html>

--f40304387f4ce9fdcb054ceb965f--