consumer Questions
3
Solved
I read you can have multiple consumer apps per kinesis stream.
http://docs.aws.amazon.com/kinesis/latest/dev/developing-consumers-with-kcl.html
however, I heard you can only have one consumer per s...
Traction asked 29/12, 2015 at 1:34
5
Solved
I am using RabbitMQ and I have a queue that holds email messages. My consumer service de-queues messages and attempts to send them. If, for any reason, my consumer cannot send the message, I would ...
1
I have a RabbitMQ queue in which I post thousands of messages. I need a background Service that will:
Retrieve the messages in batches of 100 messages
Store those 100 messages in a Database
Ack al...
Crutch asked 20/5, 2022 at 8:32
3
Solved
Is there any way to throw an Exception while using a consumer in java 8?
For example:
private void fooMethod(List<String> list) throws Exception {
list.forEach(element->{
if(element....
3
Solved
I have been searching for C++ kafka consumer. I came across following which are for C++ kafka but there is no consumer.
https://github.com/adobe-research/libkafka (Only sample producer)
https://...
Mohair asked 22/7, 2014 at 10:1
3
Solved
I've got an application which has some bugs. For some reason 2 consumers are created when only one should be there - and one of them is not checked for messages anymore.
I can detect that situatio...
0
I need to consume SQS events with my rails application. I've written a Sidekiq job which does a long polling like this:
class SqsConsumerWorker
include Sidekiq::Worker
def perform
...
poller ...
Grease asked 16/9, 2021 at 10:58
3
Solved
I am using Kafka (kafka-python) version 3.0.0-1.3.0.0.p0.40. I need to configure the consumer for the topic 'simulation' in Python. When I don't indicate the group_id, i.e. group_id = None it recei...
Didynamous asked 21/9, 2018 at 0:48
3
Solved
I have a need in a block of code to consume 'n' items from a stream then finish, in essence:
public static <T> void eat(Stream<T> stream, int n)
// consume n items of the stream (an...
Vulgate asked 10/2, 2016 at 4:18
3
I have a two-nodes Kafka cluster (EC2 instances) where each node is used as a separate broker. When I run a producer on the leader instance with the following command:
kafka-console-producer.sh --...
Implore asked 9/1, 2017 at 13:30
2
Solved
I changed the consumer-group-id of my web service listening to a Kafka topic. Now, the old group id is still registered to the topic, but there is no consumer with that group id. Therefore, it is l...
Insobriety asked 2/9, 2020 at 11:54
1
Solved
In this project I'm using React.createContext() methode to manage the state.
I can access to the state data by importing the Context.Consumer and using this consumer in the return methode of the c...
Wendolynwendt asked 29/11, 2020 at 14:11
1
I use Messenger Component in a non-Symfony project and Doctrine as a DSN transport. Now I want to test my code and consume the messages on my local machine, but I don't know how to run the messenge...
Wilsonwilt asked 25/11, 2020 at 13:37
2
Solved
So as it goes in the current scenario, we have a set of APIs as listed below:
Consumer<T> start();
Consumer<T> performDailyAggregates();
Consumer<T> performLastNDaysAggregates();...
Leer asked 23/1, 2020 at 17:17
3
Solved
I am using pactNet to test an API which should return an array of a flexible length.
If i call "myApi/items/" it should return a list of items where the consumer does not know the exact size of.
S...
3
Solved
I want to get the next element from a spliterator, not just "perform action" on the next element. For example by implementing the following method
<T> T getnext(Spliterator<T> s) {
}
...
Gumbo asked 6/9, 2019 at 10:26
1
Solved
I am using MassTransit 5.5.5 version and xunit 2.4.1
My consumer looks like this
public class StorageInformationConsumer : IConsumer<CreateStorageInformationSummary>
{
private readonly IBu...
Lonnalonnard asked 29/8, 2019 at 23:11
1
Solved
There are several questions here in SO about RabbitMQ heartbeat but I haven't found one addressing how to actually change the default heartbeat value of 60 seconds (580 seconds in previous versions...
Crosier asked 4/7, 2019 at 11:16
1
I have a requirement to upgrade our Producer/Consumer infrastructure.
The current setup look like this:
Set of 3 queues with different priority (low, med, high).
When one our customers generate ...
Conjurer asked 13/9, 2017 at 10:1
3
Solved
While using the disruptor, there may be a consumer(s) that is lagging behind, and because of that slow consumer, the whole application is affected.
Keeping in mind that every producer(Publisher) ...
Bremser asked 23/7, 2012 at 3:25
1
Solved
I simply try to use react provider but somehow i get this error:
index.js:1437 Warning: A context consumer was rendered with multiple children, or a child that isn't a function. A context consumer ...
3
Is there a small and concise jvm consumer Java (consumer or provider) junit project that somebody could share, preferably in a self contained zip file with all files contained, except for the jar i...
3
Solved
Looking for how to use Java lambda functions so Consumer can process all objects provided by a Supplier, and get rid of the explicit while loop and null checks.
I have a Supplier of String keys fo...
Logy asked 19/12, 2018 at 4:49
1
Solved
I am trying to make use of mirror maker to replicate __consumer_offsets topic along with other topics.
It is giving error as mentioned below.
[2018-10-24 16:16:03,802] ERROR Error when sending mes...
Loophole asked 24/10, 2018 at 11:20
1
Solved
I am learning Kafka and I want to know how to specify the partition when I consume messages from a topic.
I have found several pictures like this:
It means that a consumer can consume messages fro...
Chinkiang asked 29/9, 2017 at 15:57
1 Next >
© 2022 - 2025 — McMap. All rights reserved.