Tag: consumer
Producer-Consumer mit threads
5 Antworten
Ich Schreibe ein Programm implementiert, dass die Erzeuger-Verbraucher-problem in Java mit multithreading-Konzepte. Unten sind einige details, wie ich bin, soll es tun: 1) Der Haupt-thread sollte erstellen Sie einen Puffer mit der Kapazität angegeben als Kommandozeilen-argument. Die
Wie aufzuhören Nachricht von selektiven queue RabbitMQ
1 Antworten
QueueingConsumer consumer = new QueueingConsumer(channel); System.out.println(consumer.getConsumerTag()); channel.basicConsume("queue1", consumer); channel.basicConsume("queue3", consumer); Ist es möglich, aufzuhören die Nachrichten aus der Warteschlange "queue3" allein dynamisch? InformationsquelleAutor user1182253 | 2014-04-28
Weg zu brechen, dass eine Verbindung von rabbitmq
2 Antworten
Ich habe eine Anwendung, die einige bugs hat. Für einige Grund 2 die Verbraucher werden erstellt, wenn nur eine da sein sollte - und einer von Ihnen ist nicht geprüft für Nachrichten mehr. Kann ich erkennen, dass
mehrere Konsumenten pro kinesis-Splitter
2 Antworten
Ich gelesen man kann mehrere consumer apps im kinesis-stream. http://docs.aws.amazon.com/kinesis/latest/dev/developing-consumers-with-kcl.html aber ich habe gehört, Sie können nur auf Verbraucher pro shard. Ist das wahr? Ich nicht finden, keine Dokumentation, um diese zu unterstützen, und kann mir nicht
Nachrichten Lesen offset in Apache Kafka
1 Antworten
Bin ich sehr viel neues Kafka und wir sind mit Kafka 0.8.1. Was ich tun müssen, ist zu konsumieren, eine Nachricht von Thema. Für, die, ich Schreibe ein Verbraucher in Java, die verbrauchen eine Meldung von Thema
Thema kann nicht gefunden werden bei der Produktion von Nachrichten: UNKNOWN_TOPIC_OR_PARTITION
1 Antworten
Ich habe einen zwei-Knoten-kafka-cluster (EC2-Instanzen), bei denen jeder Knoten wird als ein separates broker. Wenn ich ein Produzent auf die leader-Instanz mit folgendem Befehl: kafka-console-producer.sh --broker-list localhost:9092 --topic test Bekomme ich folgenden Fehler. test-Nachricht [2017-01-09 13:22:39,483] WARN
Kafka High-Level-Verbraucher holt Alle Nachrichten Aus Thema Mit Hilfe der Java-API (Entspricht-von-Anfang)
4 Antworten
Teste ich das Kafka Hohe Verbraucher über die ConsumerGroupExample code aus dem Kafka-Website. Ich möchte zum abrufen aller vorhandenen Nachrichten über das Thema namens "test", dass ich in der Kafka-server config. Ein Blick auf andere blogs, auto.offset.reset
Wie setze ich eine Anzahl der Wiederholungsversuche in RabbitMQ?
1 Antworten
Ich bin mit RabbitMQ und ich habe eine Warteschlange, in der E-Mail-Nachrichten. Meine Verbraucher-service-de-Warteschlangen-Nachrichten und versucht, Sie zu senden. Wenn, aus irgendeinem Grund, meine Verbraucher nicht die Nachricht zu senden, möchte ich erneut in die Warteschlange der
Schnelle und beste Producer / Consumer-Queue-Technik BlockingCollection vs gleichzeitige Warteschlange
1 Antworten
Im mit Generika.Warteschlange in C# 3.0 und Überwachen.Eingeben,warten,Ausfahrt warten, vor der Einnahme der Warteschlange (warten Sie, bis das element in die Warteschlange eingereiht). Jetzt im übergang zu C# 4. Kann mir jemand empfehlen, welche man blitzschnell und
Wie kann ich eine Nachricht von der WEB API abrufen?
5 Antworten
Ich habe einige web-apis und-wenn ein Fehler passiert, die api gibt HttpResponseMessage, die erstellt wird, mit CreateErrorResponse Nachricht. So etwas wie dieses: return Request.CreateErrorResponse( HttpStatusCode.NotFound, "Failed to find customer."); Mein problem ist, dass ich kann nicht herausfinden,
Wie implementiere ich sichere OAuth2-Nutzung in Javascript?
2 Antworten
Ich bin in den Prozess der Gestaltung einer API in PHP verwenden OAuth2.0. Mein end-Ziel ist der Aufbau eines front-end-Anwendung in javascript (mit AngularJS), die auf diese API direkt. Ich weiß, dass traditionell gibt es keine Möglichkeit,
Bibliothek für OAuth-Provider (Java)
6 Antworten
Ich bin auf der Suche nach eine Java-Bibliothek, die mir hilft, Gebäude zu einem OAuth Provider. Ich muss in der Lage sein, um erhalten OAuth signierten Anfragen und festzustellen, ob Sie gültig sind oder nicht (überprüfung der