python (12.9k questions)

javascript (9.2k questions)

reactjs (4.7k questions)

java (4.2k questions)

java (4.2k questions)

c# (3.5k questions)

c# (3.5k questions)

html (3.3k questions)

Questions - consumer

confluent-kafka Timed out OffsetCommitRequest

im using confluent-kafka 1.8.2. Faced a problem, after N messages the consumer crashes with an error. GroupCoordinator/5: Timed out OffsetCommitRequest in flight (after 60165ms, timeout #0) Please hel...
test-img

Дима Январёв

python

consumer

confluent-kafka-python

Votes: 0

Answers: 0

golang producer consumer number of messages received

I have written producer-consumer pattern in golang. Reading multiple csv files and processing records. I am reading all records of csv file in one go. I want to log percentage of processing completion...
test-img

rahulpareekyx

go

channel

consumer

producer

Votes: 0

Answers: 1

Latest Answer

I have used atomic variable & counter channel where consumer will push count when record is processed & other goroutine will read from channel & calculate total processed record percentage...
test-img

rahulpareekyx

My javax.jms.MessageListener stops receiving messages from IBM MQ Server

I am building a service that continuously consumes messages from a IBM MQ Queue. This service runs in a private cloud with 80 replicas (containers or PODs) listening to the queue. Observing the applic...
test-img

leandro.marques

listener

ibm-mq

message-queue

consumer

Votes: 0

Answers: 0

Posts

Questions

Blogs

Jobs