spring-cloud-stream

0Hitze

2Antwort

Frühling Integration/Frühjahr Cloud Stream: Wie eine einzelne Nachricht senden @inboundchanneladapter mit

Ich habe das folgende Stück Code: @Bean @InboundChannelAdapter(value = Source.OUTPUT, poller = @Poller(fixedDelay = "${fixedDelay}", maxMessagesPerPoll = "1")) public MessageSource<String> t

0Hitze

1Antwort

Wie man Ströme mit "Kriterien" in SCDF einsetzt

In this Führer wird erwähnt, dass während der Entwicklung eines Stromes man für jedes Modul eine Eigenschaft "Kriterium" spezifizieren kann. z.B. dataflow:> stream deploy --name ticktock --properties

0Hitze

1Antwort

Wie wählen Kafka Thema dynamisch mit Spring Cloud Stream

Ich habe eine Event-Klasse. Die Zieleigenschaft ist der Name des Kafka-Themas. Wie kann ich eine Nachricht an das Ziel veröffentlichen. Ich kann das Ziel in application.properties nicht setzen, da das

0Hitze

1Antwort

spring-cloud-stream Feldfehler im Objekt 'spring.cloud.stream' auf Feld 'Bindungen [Eingabe]'

Ich untersuche den Feder-Wolke-Strom, traf einige Probleme. @EnableBinding(Source.class) public class SendSource { private String format = "yyyy-MM-dd HH:mm:ss"; @Bean @InboundChanne

0Hitze

2Antwort

Einige Probleme beim Ausführen von Feder-Wolke-Strom-Proben

Ich habe die Anwendung https://github.com/spring-cloud/spring-cloud-stream-samples/tree/master/stream-listener, einige Fehler, warum? Sending value: hi of type class demo.domain.Foo 2016-04-07 19:19:

2Hitze

2Antwort

StringIndexOutOfBoundsException von EmbeddedHeadersMessageConverter

Ich bin dabei, eine einfache Kafka Consumer-Anwendung aus einem bestehenden Framework zu entfernen und fühle mich wie Feder-Cloud-Stream ist eine einfache Möglichkeit, das zu tun. Ich habe Initializr

3Hitze

2Antwort

microservice messaging db-assigned identifiers

Die Firma, für die ich arbeite, untersucht den Wechsel von unserer derzeitigen monolithischen API zu Microservices. Unsere aktuelle API ist stark vom Frühling abhängig und wir verwenden SQL Server für

2Hitze

1Antwort

ConcurrentModificationException bei der Verwendung von Spring Integration DSL Mail

Ich versuche Spring Integration Java DSL für das Empfangen von E-Mail (Gmail) zu verwenden. Ich benutze auch Redis. Wenn ich Mail erhalte, erhalte ich ConcurrentModificationException. Bei der Suche ha

2Hitze

1Antwort

Spring Cloud Stream DataFlow - Treiberklasse kann nicht geladen werden: com.mysql.jdbc.Driver

Ich teste gerade das Beispiel dieser URL HTTP to MySQL wo der Zweck ist, einen Stream von http zu einer MySQL-Datenbank zu erstellen. Gemäß dem Beispiel werden alle Informationen bezüglich der jdbc-Ve

5Hitze

2Antwort

spring cloud stream 'bindingService' Fehler

Ich versuche Turbine AMQP zu implementieren, um den gesamten Stream von mehreren Diensten zu Hystrix Dashboard zu konsolidieren. Also habe ich paar Abhängigkeiten zu der Gradle-Datei hinzugefügt und d