Windham (DrKN) Wong
Windham (DrKN) Wong
How about Apache Lucene, same using in elasticsearch, but Apache licensed
Confirmed working if changing `stmgrId` to `stmgr_id`. See if anyone has the same issue, i have created PR
I currently have the Kafka spout code working, however, it falls after some time randomly (around 2 - 7 days). It shows initialized but nothing received from the Kafka broker....
My Kafka Spout is more like a standard Lafka client in Python and emitting messages in Heron. It appears stop emitting after some time (random time period) and now just...
For reference only def next_tuple(self): msg = self.CONFLUENT_CONSUMER.poll(0.1) if msg is None: return if msg.error(): if msg.error().code() == KafkaError._PARTITION_EOF: return else: self.log("[*] [ERROR] " + msg.error()) return self.emit([msg.value()])
Confirmed that this happens when using helm, setting `.Values.zookeeper.security := true`.
Great! So it can append the log files every time :D
I will leave this for while, since I am not sure of which logging method should I write into.
I highly recommend you all using the strict regex. In this case, I suggest `www\.[\w\d-_]*\.co(m|\.\w+)` to catch the URL. If you want to examine or test out regex, please try...