bakansm
diff --git a/‎HDSD.txt
+13-4 b/‎HDSD.txt
+13-4
diff --git a/‎consumer.py
+4-4 b/‎consumer.py
+4-4
diff --git a/‎kafka-ml-test/checkpoint/.metadata.crc
-12 Bytes b/‎kafka-ml-test/checkpoint/.metadata.crc
-12 Bytes
diff --git a/‎kafka-ml-test/checkpoint/commits/.0.crc
-12 Bytes b/‎kafka-ml-test/checkpoint/commits/.0.crc
-12 Bytes
diff --git a/‎kafka-ml-test/checkpoint/commits/.1.crc
-12 Bytes b/‎kafka-ml-test/checkpoint/commits/.1.crc
-12 Bytes
diff --git a/‎kafka-ml-test/checkpoint/commits/.10.crc
-12 Bytes b/‎kafka-ml-test/checkpoint/commits/.10.crc
-12 Bytes
diff --git a/‎kafka-ml-test/checkpoint/commits/.11.crc
-12 Bytes b/‎kafka-ml-test/checkpoint/commits/.11.crc
-12 Bytes
diff --git a/‎kafka-ml-test/checkpoint/commits/.12.crc
-12 Bytes b/‎kafka-ml-test/checkpoint/commits/.12.crc
-12 Bytes
diff --git a/‎kafka-ml-test/checkpoint/commits/.13.crc
-12 Bytes b/‎kafka-ml-test/checkpoint/commits/.13.crc
-12 Bytes
diff --git a/‎kafka-ml-test/checkpoint/commits/.14.crc
-12 Bytes b/‎kafka-ml-test/checkpoint/commits/.14.crc
-12 Bytes
diff --git a/‎kafka-ml-test/checkpoint/commits/.15.crc
-12 Bytes b/‎kafka-ml-test/checkpoint/commits/.15.crc
-12 Bytes
diff --git a/‎kafka-ml-test/checkpoint/commits/.16.crc
-12 Bytes b/‎kafka-ml-test/checkpoint/commits/.16.crc
-12 Bytes
diff --git a/‎kafka-ml-test/checkpoint/commits/.17.crc
-12 Bytes b/‎kafka-ml-test/checkpoint/commits/.17.crc
-12 Bytes
diff --git a/‎kafka-ml-test/checkpoint/commits/.18.crc
-12 Bytes b/‎kafka-ml-test/checkpoint/commits/.18.crc
-12 Bytes
diff --git a/‎kafka-ml-test/checkpoint/commits/.19.crc
-12 Bytes b/‎kafka-ml-test/checkpoint/commits/.19.crc
-12 Bytes
diff --git a/‎kafka-ml-test/checkpoint/commits/.2.crc
-12 Bytes b/‎kafka-ml-test/checkpoint/commits/.2.crc
-12 Bytes
diff --git a/‎kafka-ml-test/checkpoint/commits/.20.crc
-12 Bytes b/‎kafka-ml-test/checkpoint/commits/.20.crc
-12 Bytes
diff --git a/‎kafka-ml-test/checkpoint/commits/.21.crc
-12 Bytes b/‎kafka-ml-test/checkpoint/commits/.21.crc
-12 Bytes
diff --git a/‎kafka-ml-test/checkpoint/commits/.22.crc
-12 Bytes b/‎kafka-ml-test/checkpoint/commits/.22.crc
-12 Bytes
diff --git a/‎kafka-ml-test/checkpoint/commits/.23.crc
-12 Bytes b/‎kafka-ml-test/checkpoint/commits/.23.crc
-12 Bytes
diff --git a/‎kafka-ml-test/checkpoint/commits/.24.crc
-12 Bytes b/‎kafka-ml-test/checkpoint/commits/.24.crc
-12 Bytes
diff --git a/‎kafka-ml-test/checkpoint/commits/.25.crc
-12 Bytes b/‎kafka-ml-test/checkpoint/commits/.25.crc
-12 Bytes
diff --git a/‎kafka-ml-test/checkpoint/commits/.26.crc
-12 Bytes b/‎kafka-ml-test/checkpoint/commits/.26.crc
-12 Bytes
diff --git a/‎kafka-ml-test/checkpoint/commits/.27.crc
-12 Bytes b/‎kafka-ml-test/checkpoint/commits/.27.crc
-12 Bytes
diff --git a/‎kafka-ml-test/checkpoint/commits/.28.crc
-12 Bytes b/‎kafka-ml-test/checkpoint/commits/.28.crc
-12 Bytes
diff --git a/‎kafka-ml-test/checkpoint/commits/.29.crc
-12 Bytes b/‎kafka-ml-test/checkpoint/commits/.29.crc
-12 Bytes
diff --git a/‎kafka-ml-test/checkpoint/commits/.3.crc
-12 Bytes b/‎kafka-ml-test/checkpoint/commits/.3.crc
-12 Bytes
diff --git a/‎kafka-ml-test/checkpoint/commits/.30.crc
-12 Bytes b/‎kafka-ml-test/checkpoint/commits/.30.crc
-12 Bytes
diff --git a/‎kafka-ml-test/checkpoint/commits/.31.crc
-12 Bytes b/‎kafka-ml-test/checkpoint/commits/.31.crc
-12 Bytes
diff --git a/‎kafka-ml-test/checkpoint/commits/.32.crc
-12 Bytes b/‎kafka-ml-test/checkpoint/commits/.32.crc
-12 Bytes
diff --git a/‎kafka-ml-test/checkpoint/commits/.33.crc
-12 Bytes b/‎kafka-ml-test/checkpoint/commits/.33.crc
-12 Bytes
diff --git a/‎kafka-ml-test/checkpoint/commits/.34.crc
-12 Bytes b/‎kafka-ml-test/checkpoint/commits/.34.crc
-12 Bytes
diff --git a/‎kafka-ml-test/checkpoint/commits/.35.crc
-12 Bytes b/‎kafka-ml-test/checkpoint/commits/.35.crc
-12 Bytes
diff --git a/‎kafka-ml-test/checkpoint/commits/.36.crc
-12 Bytes b/‎kafka-ml-test/checkpoint/commits/.36.crc
-12 Bytes
diff --git a/‎kafka-ml-test/checkpoint/commits/.37.crc
-12 Bytes b/‎kafka-ml-test/checkpoint/commits/.37.crc
-12 Bytes
diff --git a/‎kafka-ml-test/checkpoint/commits/.38.crc
-12 Bytes b/‎kafka-ml-test/checkpoint/commits/.38.crc
-12 Bytes
diff --git a/‎kafka-ml-test/checkpoint/commits/.39.crc
-12 Bytes b/‎kafka-ml-test/checkpoint/commits/.39.crc
-12 Bytes
diff --git a/‎kafka-ml-test/checkpoint/commits/.4.crc
-12 Bytes b/‎kafka-ml-test/checkpoint/commits/.4.crc
-12 Bytes
diff --git a/‎kafka-ml-test/checkpoint/commits/.40.crc
-12 Bytes b/‎kafka-ml-test/checkpoint/commits/.40.crc
-12 Bytes
diff --git a/‎kafka-ml-test/checkpoint/commits/.41.crc
-12 Bytes b/‎kafka-ml-test/checkpoint/commits/.41.crc
-12 Bytes
diff --git a/‎kafka-ml-test/checkpoint/commits/.42.crc
-12 Bytes b/‎kafka-ml-test/checkpoint/commits/.42.crc
-12 Bytes
diff --git a/‎kafka-ml-test/checkpoint/commits/.43.crc
-12 Bytes b/‎kafka-ml-test/checkpoint/commits/.43.crc
-12 Bytes
diff --git a/‎kafka-ml-test/checkpoint/commits/.44.crc
-12 Bytes b/‎kafka-ml-test/checkpoint/commits/.44.crc
-12 Bytes
diff --git a/‎kafka-ml-test/checkpoint/commits/.45.crc
-12 Bytes b/‎kafka-ml-test/checkpoint/commits/.45.crc
-12 Bytes
diff --git a/‎kafka-ml-test/checkpoint/commits/.46.crc
-12 Bytes b/‎kafka-ml-test/checkpoint/commits/.46.crc
-12 Bytes
diff --git a/‎kafka-ml-test/checkpoint/commits/.47.crc
-12 Bytes b/‎kafka-ml-test/checkpoint/commits/.47.crc
-12 Bytes
diff --git a/‎kafka-ml-test/checkpoint/commits/.48.crc
-12 Bytes b/‎kafka-ml-test/checkpoint/commits/.48.crc
-12 Bytes
diff --git a/‎kafka-ml-test/checkpoint/commits/.49.crc
-12 Bytes b/‎kafka-ml-test/checkpoint/commits/.49.crc
-12 Bytes
diff --git a/‎kafka-ml-test/checkpoint/commits/.5.crc
-12 Bytes b/‎kafka-ml-test/checkpoint/commits/.5.crc
-12 Bytes
diff --git a/‎kafka-ml-test/checkpoint/commits/.50.crc
-12 Bytes b/‎kafka-ml-test/checkpoint/commits/.50.crc
-12 Bytes
diff --git a/‎kafka-ml-test/checkpoint/commits/.51.crc
-12 Bytes b/‎kafka-ml-test/checkpoint/commits/.51.crc
-12 Bytes
diff --git a/‎kafka-ml-test/checkpoint/commits/.52.crc
-12 Bytes b/‎kafka-ml-test/checkpoint/commits/.52.crc
-12 Bytes
diff --git a/‎kafka-ml-test/checkpoint/commits/.53.crc
-12 Bytes b/‎kafka-ml-test/checkpoint/commits/.53.crc
-12 Bytes
diff --git a/‎kafka-ml-test/checkpoint/commits/.54.crc
-12 Bytes b/‎kafka-ml-test/checkpoint/commits/.54.crc
-12 Bytes
diff --git a/‎kafka-ml-test/checkpoint/commits/.55.crc
-12 Bytes b/‎kafka-ml-test/checkpoint/commits/.55.crc
-12 Bytes
diff --git a/‎kafka-ml-test/checkpoint/commits/.56.crc
-12 Bytes b/‎kafka-ml-test/checkpoint/commits/.56.crc
-12 Bytes
diff --git a/‎kafka-ml-test/checkpoint/commits/.57.crc
-12 Bytes b/‎kafka-ml-test/checkpoint/commits/.57.crc
-12 Bytes
diff --git a/‎kafka-ml-test/checkpoint/commits/.58.crc
-12 Bytes b/‎kafka-ml-test/checkpoint/commits/.58.crc
-12 Bytes
diff --git a/‎kafka-ml-test/checkpoint/commits/.59.crc
-12 Bytes b/‎kafka-ml-test/checkpoint/commits/.59.crc
-12 Bytes
diff --git a/‎kafka-ml-test/checkpoint/commits/.6.crc
-12 Bytes b/‎kafka-ml-test/checkpoint/commits/.6.crc
-12 Bytes
diff --git a/‎kafka-ml-test/checkpoint/commits/.60.crc
-12 Bytes b/‎kafka-ml-test/checkpoint/commits/.60.crc
-12 Bytes
diff --git a/‎kafka-ml-test/checkpoint/commits/.61.crc
-12 Bytes b/‎kafka-ml-test/checkpoint/commits/.61.crc
-12 Bytes
diff --git a/‎kafka-ml-test/checkpoint/commits/.62.crc
-12 Bytes b/‎kafka-ml-test/checkpoint/commits/.62.crc
-12 Bytes
diff --git a/‎kafka-ml-test/checkpoint/commits/.63.crc
-12 Bytes b/‎kafka-ml-test/checkpoint/commits/.63.crc
-12 Bytes
diff --git a/‎kafka-ml-test/checkpoint/commits/.64.crc
-12 Bytes b/‎kafka-ml-test/checkpoint/commits/.64.crc
-12 Bytes
diff --git a/‎kafka-ml-test/checkpoint/commits/.65.crc
-12 Bytes b/‎kafka-ml-test/checkpoint/commits/.65.crc
-12 Bytes
diff --git a/‎kafka-ml-test/checkpoint/commits/.66.crc
-12 Bytes b/‎kafka-ml-test/checkpoint/commits/.66.crc
-12 Bytes
diff --git a/‎kafka-ml-test/checkpoint/commits/.7.crc
-12 Bytes b/‎kafka-ml-test/checkpoint/commits/.7.crc
-12 Bytes
diff --git a/‎kafka-ml-test/checkpoint/commits/.8.crc
-12 Bytes b/‎kafka-ml-test/checkpoint/commits/.8.crc
-12 Bytes
diff --git a/‎kafka-ml-test/checkpoint/commits/.9.crc
-12 Bytes b/‎kafka-ml-test/checkpoint/commits/.9.crc
-12 Bytes
diff --git a/‎kafka-ml-test/checkpoint/commits/0
-2 b/‎kafka-ml-test/checkpoint/commits/0
-2
diff --git a/‎kafka-ml-test/checkpoint/commits/1
-2 b/‎kafka-ml-test/checkpoint/commits/1
-2
diff --git a/‎kafka-ml-test/checkpoint/commits/10
-2 b/‎kafka-ml-test/checkpoint/commits/10
-2
diff --git a/‎kafka-ml-test/checkpoint/commits/11
-2 b/‎kafka-ml-test/checkpoint/commits/11
-2
diff --git a/‎kafka-ml-test/checkpoint/commits/12
-2 b/‎kafka-ml-test/checkpoint/commits/12
-2
diff --git a/‎kafka-ml-test/checkpoint/commits/13
-2 b/‎kafka-ml-test/checkpoint/commits/13
-2
diff --git a/‎kafka-ml-test/checkpoint/commits/14
-2 b/‎kafka-ml-test/checkpoint/commits/14
-2
diff --git a/‎kafka-ml-test/checkpoint/commits/15
-2 b/‎kafka-ml-test/checkpoint/commits/15
-2
diff --git a/‎kafka-ml-test/checkpoint/commits/16
-2 b/‎kafka-ml-test/checkpoint/commits/16
-2
diff --git a/‎kafka-ml-test/checkpoint/commits/17
-2 b/‎kafka-ml-test/checkpoint/commits/17
-2
diff --git a/‎kafka-ml-test/checkpoint/commits/18
-2 b/‎kafka-ml-test/checkpoint/commits/18
-2
diff --git a/‎kafka-ml-test/checkpoint/commits/19
-2 b/‎kafka-ml-test/checkpoint/commits/19
-2
diff --git a/‎kafka-ml-test/checkpoint/commits/2
-2 b/‎kafka-ml-test/checkpoint/commits/2
-2
diff --git a/‎kafka-ml-test/checkpoint/commits/20
-2 b/‎kafka-ml-test/checkpoint/commits/20
-2
diff --git a/‎kafka-ml-test/checkpoint/commits/21
-2 b/‎kafka-ml-test/checkpoint/commits/21
-2
diff --git a/‎kafka-ml-test/checkpoint/commits/22
-2 b/‎kafka-ml-test/checkpoint/commits/22
-2
diff --git a/‎kafka-ml-test/checkpoint/commits/23
-2 b/‎kafka-ml-test/checkpoint/commits/23
-2
diff --git a/‎kafka-ml-test/checkpoint/commits/24
-2 b/‎kafka-ml-test/checkpoint/commits/24
-2
diff --git a/‎kafka-ml-test/checkpoint/commits/25
-2 b/‎kafka-ml-test/checkpoint/commits/25
-2
diff --git a/‎kafka-ml-test/checkpoint/commits/26
-2 b/‎kafka-ml-test/checkpoint/commits/26
-2
diff --git a/‎kafka-ml-test/checkpoint/commits/27
-2 b/‎kafka-ml-test/checkpoint/commits/27
-2
diff --git a/‎kafka-ml-test/checkpoint/commits/28
-2 b/‎kafka-ml-test/checkpoint/commits/28
-2
diff --git a/‎kafka-ml-test/checkpoint/commits/29
-2 b/‎kafka-ml-test/checkpoint/commits/29
-2
diff --git a/‎kafka-ml-test/checkpoint/commits/3
-2 b/‎kafka-ml-test/checkpoint/commits/3
-2
diff --git a/‎kafka-ml-test/checkpoint/commits/30
-2 b/‎kafka-ml-test/checkpoint/commits/30
-2
diff --git a/‎kafka-ml-test/checkpoint/commits/31
-2 b/‎kafka-ml-test/checkpoint/commits/31
-2
diff --git a/‎kafka-ml-test/checkpoint/commits/32
-2 b/‎kafka-ml-test/checkpoint/commits/32
-2
diff --git a/‎kafka-ml-test/checkpoint/commits/33
-2 b/‎kafka-ml-test/checkpoint/commits/33
-2
diff --git a/‎kafka-ml-test/checkpoint/commits/34
-2 b/‎kafka-ml-test/checkpoint/commits/34
-2
diff --git a/‎kafka-ml-test/checkpoint/commits/35
-2 b/‎kafka-ml-test/checkpoint/commits/35
-2
diff --git a/‎kafka-ml-test/checkpoint/commits/36
-2 b/‎kafka-ml-test/checkpoint/commits/36
-2
diff --git a/‎kafka-ml-test/checkpoint/commits/37
-2 b/‎kafka-ml-test/checkpoint/commits/37
-2
diff --git a/‎kafka-ml-test/checkpoint/commits/38
-2 b/‎kafka-ml-test/checkpoint/commits/38
-2
diff --git a/‎kafka-ml-test/checkpoint/commits/39
-2 b/‎kafka-ml-test/checkpoint/commits/39
-2
diff --git a/‎kafka-ml-test/checkpoint/commits/4
-2 b/‎kafka-ml-test/checkpoint/commits/4
-2
diff --git a/‎kafka-ml-test/checkpoint/commits/40
-2 b/‎kafka-ml-test/checkpoint/commits/40
-2
diff --git a/‎kafka-ml-test/checkpoint/commits/41
-2 b/‎kafka-ml-test/checkpoint/commits/41
-2
diff --git a/‎kafka-ml-test/checkpoint/commits/42
-2 b/‎kafka-ml-test/checkpoint/commits/42
-2
diff --git a/‎kafka-ml-test/checkpoint/commits/43
-2 b/‎kafka-ml-test/checkpoint/commits/43
-2
diff --git a/‎kafka-ml-test/checkpoint/commits/44
-2 b/‎kafka-ml-test/checkpoint/commits/44
-2
diff --git a/‎kafka-ml-test/checkpoint/commits/45
-2 b/‎kafka-ml-test/checkpoint/commits/45
-2
diff --git a/‎kafka-ml-test/checkpoint/commits/46
-2 b/‎kafka-ml-test/checkpoint/commits/46
-2
diff --git a/‎kafka-ml-test/checkpoint/commits/47
-2 b/‎kafka-ml-test/checkpoint/commits/47
-2
diff --git a/‎kafka-ml-test/checkpoint/commits/48
-2 b/‎kafka-ml-test/checkpoint/commits/48
-2
diff --git a/‎kafka-ml-test/checkpoint/commits/49
-2 b/‎kafka-ml-test/checkpoint/commits/49
-2
diff --git a/‎kafka-ml-test/checkpoint/commits/5
-2 b/‎kafka-ml-test/checkpoint/commits/5
-2
diff --git a/‎kafka-ml-test/checkpoint/commits/50
-2 b/‎kafka-ml-test/checkpoint/commits/50
-2
diff --git a/‎kafka-ml-test/checkpoint/commits/51
-2 b/‎kafka-ml-test/checkpoint/commits/51
-2
diff --git a/‎kafka-ml-test/checkpoint/commits/52
-2 b/‎kafka-ml-test/checkpoint/commits/52
-2
diff --git a/‎kafka-ml-test/checkpoint/commits/53
-2 b/‎kafka-ml-test/checkpoint/commits/53
-2
diff --git a/‎kafka-ml-test/checkpoint/commits/54
-2 b/‎kafka-ml-test/checkpoint/commits/54
-2
diff --git a/‎kafka-ml-test/checkpoint/commits/55
-2 b/‎kafka-ml-test/checkpoint/commits/55
-2
diff --git a/‎kafka-ml-test/checkpoint/commits/56
-2 b/‎kafka-ml-test/checkpoint/commits/56
-2
diff --git a/‎kafka-ml-test/checkpoint/commits/57
-2 b/‎kafka-ml-test/checkpoint/commits/57
-2
diff --git a/‎kafka-ml-test/checkpoint/commits/58
-2 b/‎kafka-ml-test/checkpoint/commits/58
-2
diff --git a/‎kafka-ml-test/checkpoint/commits/59
-2 b/‎kafka-ml-test/checkpoint/commits/59
-2
diff --git a/‎kafka-ml-test/checkpoint/commits/6
-2 b/‎kafka-ml-test/checkpoint/commits/6
-2
diff --git a/‎kafka-ml-test/checkpoint/commits/60
-2 b/‎kafka-ml-test/checkpoint/commits/60
-2
diff --git a/‎kafka-ml-test/checkpoint/commits/61
-2 b/‎kafka-ml-test/checkpoint/commits/61
-2
diff --git a/‎kafka-ml-test/checkpoint/commits/62
-2 b/‎kafka-ml-test/checkpoint/commits/62
-2
diff --git a/‎kafka-ml-test/checkpoint/commits/63
-2 b/‎kafka-ml-test/checkpoint/commits/63
-2
diff --git a/‎kafka-ml-test/checkpoint/commits/64
-2 b/‎kafka-ml-test/checkpoint/commits/64
-2
diff --git a/‎kafka-ml-test/checkpoint/commits/65
-2 b/‎kafka-ml-test/checkpoint/commits/65
-2
diff --git a/‎kafka-ml-test/checkpoint/commits/66
-2 b/‎kafka-ml-test/checkpoint/commits/66
-2
diff --git a/‎kafka-ml-test/checkpoint/commits/7
-2 b/‎kafka-ml-test/checkpoint/commits/7
-2
diff --git a/‎kafka-ml-test/checkpoint/commits/8
-2 b/‎kafka-ml-test/checkpoint/commits/8
-2
diff --git a/‎kafka-ml-test/checkpoint/commits/9
-2 b/‎kafka-ml-test/checkpoint/commits/9
-2
diff --git a/‎kafka-ml-test/checkpoint/metadata
-1 b/‎kafka-ml-test/checkpoint/metadata
-1
diff --git a/‎kafka-ml-test/checkpoint/offsets/.0.crc
-16 Bytes b/‎kafka-ml-test/checkpoint/offsets/.0.crc
-16 Bytes
diff --git a/‎kafka-ml-test/checkpoint/offsets/.1.crc
-16 Bytes b/‎kafka-ml-test/checkpoint/offsets/.1.crc
-16 Bytes
diff --git a/‎kafka-ml-test/checkpoint/offsets/.10.crc
-16 Bytes b/‎kafka-ml-test/checkpoint/offsets/.10.crc
-16 Bytes
diff --git a/‎kafka-ml-test/checkpoint/offsets/.11.crc
-16 Bytes b/‎kafka-ml-test/checkpoint/offsets/.11.crc
-16 Bytes
diff --git a/‎kafka-ml-test/checkpoint/offsets/.12.crc
-16 Bytes b/‎kafka-ml-test/checkpoint/offsets/.12.crc
-16 Bytes
diff --git a/‎kafka-ml-test/checkpoint/offsets/.13.crc
-16 Bytes b/‎kafka-ml-test/checkpoint/offsets/.13.crc
-16 Bytes
diff --git a/‎kafka-ml-test/checkpoint/offsets/.14.crc
-16 Bytes b/‎kafka-ml-test/checkpoint/offsets/.14.crc
-16 Bytes
diff --git a/‎kafka-ml-test/checkpoint/offsets/.15.crc
-16 Bytes b/‎kafka-ml-test/checkpoint/offsets/.15.crc
-16 Bytes
diff --git a/‎kafka-ml-test/checkpoint/offsets/.16.crc
-16 Bytes b/‎kafka-ml-test/checkpoint/offsets/.16.crc
-16 Bytes
diff --git a/‎kafka-ml-test/checkpoint/offsets/.17.crc
-16 Bytes b/‎kafka-ml-test/checkpoint/offsets/.17.crc
-16 Bytes
diff --git a/‎kafka-ml-test/checkpoint/offsets/.18.crc
-16 Bytes b/‎kafka-ml-test/checkpoint/offsets/.18.crc
-16 Bytes
diff --git a/‎kafka-ml-test/checkpoint/offsets/.19.crc
-16 Bytes b/‎kafka-ml-test/checkpoint/offsets/.19.crc
-16 Bytes
diff --git a/‎kafka-ml-test/checkpoint/offsets/.2.crc
-16 Bytes b/‎kafka-ml-test/checkpoint/offsets/.2.crc
-16 Bytes
diff --git a/‎kafka-ml-test/checkpoint/offsets/.20.crc
-16 Bytes b/‎kafka-ml-test/checkpoint/offsets/.20.crc
-16 Bytes
diff --git a/‎kafka-ml-test/checkpoint/offsets/.21.crc
-16 Bytes b/‎kafka-ml-test/checkpoint/offsets/.21.crc
-16 Bytes
diff --git a/‎kafka-ml-test/checkpoint/offsets/.22.crc
-16 Bytes b/‎kafka-ml-test/checkpoint/offsets/.22.crc
-16 Bytes
diff --git a/‎kafka-ml-test/checkpoint/offsets/.23.crc
-16 Bytes b/‎kafka-ml-test/checkpoint/offsets/.23.crc
-16 Bytes
diff --git a/‎kafka-ml-test/checkpoint/offsets/.24.crc
-16 Bytes b/‎kafka-ml-test/checkpoint/offsets/.24.crc
-16 Bytes
diff --git a/‎kafka-ml-test/checkpoint/offsets/.25.crc
-16 Bytes b/‎kafka-ml-test/checkpoint/offsets/.25.crc
-16 Bytes
diff --git a/‎kafka-ml-test/checkpoint/offsets/.26.crc
-16 Bytes b/‎kafka-ml-test/checkpoint/offsets/.26.crc
-16 Bytes
diff --git a/‎kafka-ml-test/checkpoint/offsets/.27.crc
-16 Bytes b/‎kafka-ml-test/checkpoint/offsets/.27.crc
-16 Bytes
diff --git a/‎kafka-ml-test/checkpoint/offsets/.28.crc
-16 Bytes b/‎kafka-ml-test/checkpoint/offsets/.28.crc
-16 Bytes
diff --git a/‎kafka-ml-test/checkpoint/offsets/.29.crc
-16 Bytes b/‎kafka-ml-test/checkpoint/offsets/.29.crc
-16 Bytes
diff --git a/‎kafka-ml-test/checkpoint/offsets/.3.crc
-16 Bytes b/‎kafka-ml-test/checkpoint/offsets/.3.crc
-16 Bytes
diff --git a/‎kafka-ml-test/checkpoint/offsets/.30.crc
-16 Bytes b/‎kafka-ml-test/checkpoint/offsets/.30.crc
-16 Bytes
diff --git a/‎kafka-ml-test/checkpoint/offsets/.31.crc
-16 Bytes b/‎kafka-ml-test/checkpoint/offsets/.31.crc
-16 Bytes
diff --git a/‎kafka-ml-test/checkpoint/offsets/.32.crc
-16 Bytes b/‎kafka-ml-test/checkpoint/offsets/.32.crc
-16 Bytes
diff --git a/‎kafka-ml-test/checkpoint/offsets/.33.crc
-16 Bytes b/‎kafka-ml-test/checkpoint/offsets/.33.crc
-16 Bytes
diff --git a/‎kafka-ml-test/checkpoint/offsets/.34.crc
-16 Bytes b/‎kafka-ml-test/checkpoint/offsets/.34.crc
-16 Bytes
diff --git a/‎kafka-ml-test/checkpoint/offsets/.35.crc
-16 Bytes b/‎kafka-ml-test/checkpoint/offsets/.35.crc
-16 Bytes
diff --git a/‎kafka-ml-test/checkpoint/offsets/.36.crc
-16 Bytes b/‎kafka-ml-test/checkpoint/offsets/.36.crc
-16 Bytes
diff --git a/‎kafka-ml-test/checkpoint/offsets/.37.crc
-16 Bytes b/‎kafka-ml-test/checkpoint/offsets/.37.crc
-16 Bytes
diff --git a/‎kafka-ml-test/checkpoint/offsets/.38.crc
-16 Bytes b/‎kafka-ml-test/checkpoint/offsets/.38.crc
-16 Bytes
diff --git a/‎kafka-ml-test/checkpoint/offsets/.39.crc
-16 Bytes b/‎kafka-ml-test/checkpoint/offsets/.39.crc
-16 Bytes
diff --git a/‎kafka-ml-test/checkpoint/offsets/.4.crc
-16 Bytes b/‎kafka-ml-test/checkpoint/offsets/.4.crc
-16 Bytes
diff --git a/‎kafka-ml-test/checkpoint/offsets/.40.crc
-16 Bytes b/‎kafka-ml-test/checkpoint/offsets/.40.crc
-16 Bytes
diff --git a/‎kafka-ml-test/checkpoint/offsets/.41.crc
-16 Bytes b/‎kafka-ml-test/checkpoint/offsets/.41.crc
-16 Bytes
diff --git a/‎kafka-ml-test/checkpoint/offsets/.42.crc
-16 Bytes b/‎kafka-ml-test/checkpoint/offsets/.42.crc
-16 Bytes
diff --git a/‎kafka-ml-test/checkpoint/offsets/.43.crc
-16 Bytes b/‎kafka-ml-test/checkpoint/offsets/.43.crc
-16 Bytes
diff --git a/‎kafka-ml-test/checkpoint/offsets/.44.crc
-16 Bytes b/‎kafka-ml-test/checkpoint/offsets/.44.crc
-16 Bytes
diff --git a/‎kafka-ml-test/checkpoint/offsets/.45.crc
-16 Bytes b/‎kafka-ml-test/checkpoint/offsets/.45.crc
-16 Bytes
diff --git a/‎kafka-ml-test/checkpoint/offsets/.46.crc
-16 Bytes b/‎kafka-ml-test/checkpoint/offsets/.46.crc
-16 Bytes
diff --git a/‎kafka-ml-test/checkpoint/offsets/.47.crc
-16 Bytes b/‎kafka-ml-test/checkpoint/offsets/.47.crc
-16 Bytes
diff --git a/‎kafka-ml-test/checkpoint/offsets/.48.crc
-16 Bytes b/‎kafka-ml-test/checkpoint/offsets/.48.crc
-16 Bytes
diff --git a/‎kafka-ml-test/checkpoint/offsets/.49.crc
-16 Bytes b/‎kafka-ml-test/checkpoint/offsets/.49.crc
-16 Bytes
diff --git a/‎kafka-ml-test/checkpoint/offsets/.5.crc
-16 Bytes b/‎kafka-ml-test/checkpoint/offsets/.5.crc
-16 Bytes
diff --git a/‎kafka-ml-test/checkpoint/offsets/.50.crc
-16 Bytes b/‎kafka-ml-test/checkpoint/offsets/.50.crc
-16 Bytes
diff --git a/‎kafka-ml-test/checkpoint/offsets/.51.crc
-16 Bytes b/‎kafka-ml-test/checkpoint/offsets/.51.crc
-16 Bytes
diff --git a/‎kafka-ml-test/checkpoint/offsets/.52.crc
-16 Bytes b/‎kafka-ml-test/checkpoint/offsets/.52.crc
-16 Bytes
diff --git a/‎kafka-ml-test/checkpoint/offsets/.53.crc
-16 Bytes b/‎kafka-ml-test/checkpoint/offsets/.53.crc
-16 Bytes
diff --git a/‎kafka-ml-test/checkpoint/offsets/.54.crc
-16 Bytes b/‎kafka-ml-test/checkpoint/offsets/.54.crc
-16 Bytes
diff --git a/‎kafka-ml-test/checkpoint/offsets/.55.crc
-16 Bytes b/‎kafka-ml-test/checkpoint/offsets/.55.crc
-16 Bytes
diff --git a/‎kafka-ml-test/checkpoint/offsets/.56.crc
-16 Bytes b/‎kafka-ml-test/checkpoint/offsets/.56.crc
-16 Bytes
diff --git a/‎kafka-ml-test/checkpoint/offsets/.57.crc
-16 Bytes b/‎kafka-ml-test/checkpoint/offsets/.57.crc
-16 Bytes
diff --git a/‎kafka-ml-test/checkpoint/offsets/.58.crc
-16 Bytes b/‎kafka-ml-test/checkpoint/offsets/.58.crc
-16 Bytes
diff --git a/‎kafka-ml-test/checkpoint/offsets/.59.crc
-16 Bytes b/‎kafka-ml-test/checkpoint/offsets/.59.crc
-16 Bytes
diff --git a/‎kafka-ml-test/checkpoint/offsets/.6.crc
-16 Bytes b/‎kafka-ml-test/checkpoint/offsets/.6.crc
-16 Bytes
diff --git a/‎kafka-ml-test/checkpoint/offsets/.60.crc
-16 Bytes b/‎kafka-ml-test/checkpoint/offsets/.60.crc
-16 Bytes
diff --git a/‎kafka-ml-test/checkpoint/offsets/.61.crc
-16 Bytes b/‎kafka-ml-test/checkpoint/offsets/.61.crc
-16 Bytes
diff --git a/‎kafka-ml-test/checkpoint/offsets/.62.crc
-16 Bytes b/‎kafka-ml-test/checkpoint/offsets/.62.crc
-16 Bytes
diff --git a/‎kafka-ml-test/checkpoint/offsets/.63.crc
-16 Bytes b/‎kafka-ml-test/checkpoint/offsets/.63.crc
-16 Bytes
diff --git a/‎kafka-ml-test/checkpoint/offsets/.64.crc
-16 Bytes b/‎kafka-ml-test/checkpoint/offsets/.64.crc
-16 Bytes
diff --git a/‎kafka-ml-test/checkpoint/offsets/.65.crc
-16 Bytes b/‎kafka-ml-test/checkpoint/offsets/.65.crc
-16 Bytes
diff --git a/‎kafka-ml-test/checkpoint/offsets/.66.crc
-16 Bytes b/‎kafka-ml-test/checkpoint/offsets/.66.crc
-16 Bytes
diff --git a/‎kafka-ml-test/checkpoint/offsets/.7.crc
-16 Bytes b/‎kafka-ml-test/checkpoint/offsets/.7.crc
-16 Bytes
diff --git a/‎kafka-ml-test/checkpoint/offsets/.8.crc
-16 Bytes b/‎kafka-ml-test/checkpoint/offsets/.8.crc
-16 Bytes
diff --git a/‎kafka-ml-test/checkpoint/offsets/.9.crc
-16 Bytes b/‎kafka-ml-test/checkpoint/offsets/.9.crc
-16 Bytes
diff --git a/‎kafka-ml-test/checkpoint/offsets/0
-3 b/‎kafka-ml-test/checkpoint/offsets/0
-3
diff --git a/‎kafka-ml-test/checkpoint/offsets/1
-3 b/‎kafka-ml-test/checkpoint/offsets/1
-3
diff --git a/‎kafka-ml-test/checkpoint/offsets/10
-3 b/‎kafka-ml-test/checkpoint/offsets/10
-3
diff --git a/‎kafka-ml-test/checkpoint/offsets/11
-3 b/‎kafka-ml-test/checkpoint/offsets/11
-3
diff --git a/‎kafka-ml-test/checkpoint/offsets/12
-3 b/‎kafka-ml-test/checkpoint/offsets/12
-3
diff --git a/‎kafka-ml-test/checkpoint/offsets/13
-3 b/‎kafka-ml-test/checkpoint/offsets/13
-3
diff --git a/‎kafka-ml-test/checkpoint/offsets/14
-3 b/‎kafka-ml-test/checkpoint/offsets/14
-3
diff --git a/‎kafka-ml-test/checkpoint/offsets/15
-3 b/‎kafka-ml-test/checkpoint/offsets/15
-3
diff --git a/‎kafka-ml-test/checkpoint/offsets/16
-3 b/‎kafka-ml-test/checkpoint/offsets/16
-3
diff --git a/‎kafka-ml-test/checkpoint/offsets/17
-3 b/‎kafka-ml-test/checkpoint/offsets/17
-3
diff --git a/‎kafka-ml-test/checkpoint/offsets/18
-3 b/‎kafka-ml-test/checkpoint/offsets/18
-3
diff --git a/‎kafka-ml-test/checkpoint/offsets/19
-3 b/‎kafka-ml-test/checkpoint/offsets/19
-3
diff --git a/‎kafka-ml-test/checkpoint/offsets/2
-3 b/‎kafka-ml-test/checkpoint/offsets/2
-3
diff --git a/‎kafka-ml-test/checkpoint/offsets/20
-3 b/‎kafka-ml-test/checkpoint/offsets/20
-3
diff --git a/‎kafka-ml-test/checkpoint/offsets/21
-3 b/‎kafka-ml-test/checkpoint/offsets/21
-3
diff --git a/‎kafka-ml-test/checkpoint/offsets/22
-3 b/‎kafka-ml-test/checkpoint/offsets/22
-3
diff --git a/‎kafka-ml-test/checkpoint/offsets/23
-3 b/‎kafka-ml-test/checkpoint/offsets/23
-3
@@ -1,7 +1,16 @@
 Bước 1: Chạy kafka server và zookeeper server.
 Bước 2: Submit Topic bằng lệnh "bin/kafka-topics.sh --create --topic result_BTC --bootstrap-server localhost:9092".
-Bước 2: Chạy file streamer_BTC.py bằng lệnh "spark-submit --packages org.apache.spark:spark-sql-kafka-0-10_2.12:3.3.1 stream_BTC.py".
-Bước 3: Chạy file producer.py bằng lệnh "python3 producer.py
-Bước 4: Chạy consumer bằng lệnh "bin/kafka-console-consumer.sh --topic result_BTC --bootstrap-server localhost:9092"
+Bước 3: Chạy file streamer_BTC.py bằng lệnh "spark-submit --packages org.apache.spark:spark-sql-kafka-0-10_2.12:3.3.1 stream_BTC.py".
+Bước 4: Chạy file producer.py bằng lệnh "python3 producer.py
+Bước 5: Chạy consumer bằng lệnh "bin/kafka-console-consumer.sh --topic result_BTC --bootstrap-server localhost:9092"
 
-NOTE: Ấn Ctrl+C ở tất cả các terminal để dừng.
+NOTE: Ấn Ctrl+C ở tất cả các terminal để dừng.
+
+
+
+bin/zookeeper-server-start.sh config/zookeeper.properties
+bin/kafka-server-start.sh config/server.properties
+bin/kafka-topics.sh --create --topic topic_BTC --bootstrap-server localhost:9092
+bin/kafka-console-consumer.sh --topic result --bootstrap-server localhost:9092
+bin/connect-standalone.sh config/connect-standalone.properties config/questdb-connector.properties
+spark-submit --packages org.apache.spark:spark-sql-kafka-0-10_2.12:3.3.1 test.py
@@ -8,14 +8,14 @@
 # initialize Kafka consumers and producer
 print('Starting Apache Kafka consumers and producer')
 consumer_1 = initConsumer(config['topic_1'])
-consumer_2 = initConsumer(config['topic_2'])
-consumer_3 = initConsumer(config['topic_3'])
+# consumer_2 = initConsumer(config['topic_2'])
+# consumer_3 = initConsumer(config['topic_3'])
 producer = initProducer()
 
 # intialize local dataframe
 data_1 = pd.DataFrame(columns=['time', 'value'])
-data_2 = pd.DataFrame(columns=['time', 'value'])
-data_3 = pd.DataFrame(columns=['time', 'value'])
+# data_2 = pd.DataFrame(columns=['time', 'value'])
+# data_3 = pd.DataFrame(columns=['time', 'value'])
 
 while True:
     # consume data from Kafka