kafka spout consume same data every restart topology

[최재완]

<span lang="EN-US" 
style="font-size:12.0pt;font-family:&quot;굴림&quot;,sans-serif;mso-bidi-font-family:Gulim;
mso-font-kerning:0pt">Hi
<span lang="EN-US" 
style="font-size:12.0pt;font-family:&quot;굴림&quot;,sans-serif;mso-bidi-font-family:Gulim;
mso-font-kerning:0pt"> 
<span lang="EN-US" 
style="font-size:12.0pt;font-family:&quot;굴림&quot;,sans-serif;mso-bidi-font-family:Gulim;
mso-font-kerning:0pt">I'm currently developing storm version up project
0.9.6-&gt;1.0.2
<span lang="EN-US" 
style="font-size:12.0pt;font-family:&quot;굴림&quot;,sans-serif;mso-bidi-font-family:Gulim;
mso-font-kerning:0pt"> 
<span lang="EN-US" 
style="font-size:12.0pt;font-family:&quot;굴림&quot;,sans-serif;mso-bidi-font-family:Gulim;
mso-font-kerning:0pt">I changed my project configuration and source like below
<span lang="EN-US" 
style="font-size:12.0pt;font-family:&quot;굴림&quot;,sans-serif;mso-bidi-font-family:Gulim;
mso-font-kerning:0pt">1. storm-core and storm-kafka version change 0.9.6 to
1.0.2 and kafka_2.10 0.8.2.2 in pom.xml.
<span lang="EN-US" 
style="font-size:12.0pt;font-family:&quot;굴림&quot;,sans-serif;mso-bidi-font-family:Gulim;
mso-font-kerning:0pt">2. change package path 
<span lang="EN-US" 
style="font-size:12.0pt;font-family:&quot;굴림&quot;,sans-serif;mso-bidi-font-family:Gulim;
mso-font-kerning:0pt">- backtype -&gt; org.apache
<span lang="EN-US" 
style="font-size:12.0pt;font-family:&quot;굴림&quot;,sans-serif;mso-bidi-font-family:Gulim;
mso-font-kerning:0pt">- storm.kafka -&gt; org.apache.storm.kafka
<span lang="EN-US" 
style="font-size:12.0pt;font-family:&quot;굴림&quot;,sans-serif;mso-bidi-font-family:Gulim;
mso-font-kerning:0pt">3. Change serializing code byte[] to ByteBuffer in Custom
Scheme(I used AVRO class)
<span lang="EN-US" 
style="font-size:12.0pt;font-family:&quot;굴림&quot;,sans-serif;mso-bidi-font-family:Gulim;
mso-font-kerning:0pt"> 
<span lang="EN-US" 
style="font-size:12.0pt;font-family:&quot;굴림&quot;,sans-serif;mso-bidi-font-family:Gulim;
mso-font-kerning:0pt">I started topology and my spout consume data.
<span lang="EN-US" 
style="font-size:12.0pt;font-family:&quot;굴림&quot;,sans-serif;mso-bidi-font-family:Gulim;
mso-font-kerning:0pt">But when I restarted my topology, read same data that I
restarted before and read it.
<span lang="EN-US" 
style="font-size:12.0pt;font-family:&quot;굴림&quot;,sans-serif;mso-bidi-font-family:Gulim;
mso-font-kerning:0pt"> 
<span lang="EN-US" 
style="font-size:12.0pt;font-family:&quot;굴림&quot;,sans-serif;mso-bidi-font-family:Gulim;
mso-font-kerning:0pt">I didn't change zkRoot value and id in SpoutConfig.(I
think it means kafka group id)
<span lang="EN-US" 
style="font-size:12.0pt;font-family:&quot;굴림&quot;,sans-serif;mso-bidi-font-family:Gulim;
mso-font-kerning:0pt"> 
<span lang="EN-US" 
style="font-size:12.0pt;font-family:&quot;굴림&quot;,sans-serif;mso-bidi-font-family:Gulim;
mso-font-kerning:0pt">Eventhough it occurred both local and server mode.
<span lang="EN-US" 
style="font-size:12.0pt;font-family:&quot;굴림&quot;,sans-serif;mso-bidi-font-family:Gulim;
mso-font-kerning:0pt"> 
<span lang="EN-US" 
style="font-size:12.0pt;font-family:&quot;굴림&quot;,sans-serif;mso-bidi-font-family:Gulim;
mso-font-kerning:0pt">How can I fix it? Please Help!
<span lang="EN-US" 
style="font-size:12.0pt;font-family:&quot;굴림&quot;,sans-serif;mso-bidi-font-family:Gulim;
mso-font-kerning:0pt"> 
<span lang="EN-US" 
style="font-size:12.0pt;font-family:&quot;굴림&quot;,sans-serif;mso-bidi-font-family:Gulim;
mso-font-kerning:0pt"> 
<span lang="EN-US" 
style="font-size:12.0pt;font-family:&quot;굴림&quot;,sans-serif;mso-bidi-font-family:Gulim;
mso-font-kerning:0pt">Thanks and regards<span lang="EN-US" 
style="font-size:11.0pt;mso-ascii-font-family:&quot;Malgun 
Gothic&quot;;mso-fareast-font-family:
&quot;Malgun Gothic&quot;;mso-hansi-font-family:&quot;Malgun 
Gothic&quot;;mso-bidi-font-family:
Gulim;mso-font-kerning:0pt">