**'])
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,
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.
