**'])
for msg in consumer:
#buf2 = io.BytesIO(msg.value)
print msg
#consumer.commit();
#print load(buf2,avro.schema)
On Monday, 16 December 2019 12:22:31 UTC+5:30, sounthar cs wrote:
>
> Hi All,
>
> I am trying to consume data from the existing kafka server.
>
> *I am abl
Hi All,
I am trying to consume data from the existing kafka server.
*I am able to consume it successfully through python code*.
But i want the same to be working with golang.
i have tried sarama, confluent-kafka-go & github.com/segmentio/kafka-go.
i am getting the below error:
2019/12/16 0
Hi There,
I tried it to test it.
But i am getting the below error :
# pkg-config --cflags -- eina evas ecore-evas ecore-evas ecore-input ecore
ecore-evas eina evas ecore-evas ecore-input ecore evas ecore ecore-evas
ecore-input evas
Package eina was not found in the pkg-config search path.
Per
hi there,
As of now i am using beego with session for my e-commerce website (session
stored in memory).
When i restart my program session got deleted as it is stored in memory.
To resolve this problem i want to use session with db in beego.
Can anyone give me sample coding?
--
You received
Hi there,
As of now i am using using for E-commerce website with in-memory session.
When i restart my program all the session becomes empty (deleted because
session stored in program memory).
To resolve this i want to use mysql for session storage. I tried to find a
example, but i could not.