Mailing-List: contact user-help@flink.apache.org; run by ezmlm
Precedence: bulk
Reply-To: user@flink.apache.org
From: Paul Joireman <paul.joireman@physiq.com>
To: "user@flink.apache.org" <user@flink.apache.org>
Subject: Getting key from keyed stream
Thread-Topic: Getting key from keyed stream
Thread-Index: AQHSbRT7a/nIzda/NkaAp2rYWgmFQw==
Date: Thu, 12 Jan 2017 20:53:52 +0000
Message-ID: <CY1PR02MB19953697948102483676A23A80790@CY1PR02MB1995.namprd02.prod.outlook.com>
Accept-Language: en-US
Content-Language: en-US
received-spf: None (protection.outlook.com: physiq.com does not designate
 permitted sender hosts)
spamdiagnosticoutput: 1:99
spamdiagnosticmetadata: NSPM
Content-Type: multipart/alternative;
	boundary="_000_CY1PR02MB19953697948102483676A23A80790CY1PR02MB1995namp_"
MIME-Version: 1.0
X-MS-Exchange-CrossTenant-originalarrivaltime: 12 Jan 2017 20:53:52.6808
 (UTC)
X-MS-Exchange-CrossTenant-fromentityheader: Hosted
X-MS-Exchange-CrossTenant-id: ecbda8f3-3c3b-43e4-9663-6beab1acd10b
X-MS-Exchange-Transport-CrossTenantHeadersStamped: CY1PR02MB1995
archived-at: Thu, 12 Jan 2017 20:54:10 -0000

--_000_CY1PR02MB19953697948102483676A23A80790CY1PR02MB1995namp_
Content-Type: text/plain; charset="iso-8859-1"
Content-Transfer-Encoding: quoted-printable

Hi all,


Is there a simple way to read the key from a KeyedStream.   Very simply I'm=
 trying to read a message from Kafka, separate the incoming messages by a f=
ield in the message and write the original message back to Kafka using that=
 field as a new topic.  I chose to partition the incoming stream by creatin=
g a KeyedStream and using the field from the message as the key.    The onl=
y thing left is to write the message to Kafka with a producer but i need to=
 know the topic to write to and for that I need to be able to read the key.=
   Is there a way to do this?


Is there a better way to do this, rather than using a KeyedStream.


Paul

--_000_CY1PR02MB19953697948102483676A23A80790CY1PR02MB1995namp_
Content-Type: text/html; charset="iso-8859-1"
Content-Transfer-Encoding: quoted-printable

<html>
<head>
<meta http-equiv=3D"Content-Type" content=3D"text/html; charset=3Diso-8859-=
1">
<style type=3D"text/css" style=3D"display:none;"><!-- P {margin-top:0;margi=
n-bottom:0;} --></style>
</head>
<body dir=3D"ltr">
<div id=3D"divtagdefaultwrapper" style=3D"font-size:12pt;color:#000000;font=
-family:Calibri,Arial,Helvetica,sans-serif;" dir=3D"ltr">
<p>Hi all,</p>
<p><br>
</p>
<p>Is there a simple way to read the key from a KeyedStream. &nbsp; Very si=
mply I'm trying to read a message from Kafka, separate the incoming message=
s by a field in the message and write the original message back to Kafka us=
ing that field as a new topic. &nbsp;I chose
 to partition the incoming stream by creating a KeyedStream and using the f=
ield from the message as the key. &nbsp; &nbsp;The only thing left is to wr=
ite the message to Kafka with a producer but i need to know the topic to wr=
ite to and for that I need to be able to read
 the key. &nbsp; Is there a way to do this?</p>
<p><br>
</p>
<p>Is there a better way to do this, rather than using a KeyedStream.</p>
<p><br>
</p>
<p>Paul</p>
</div>
</body>
</html>

--_000_CY1PR02MB19953697948102483676A23A80790CY1PR02MB1995namp_--