spring-cloud/spring-cloud-stream-samples

Issues

• Add a sample demonstrating a batch consumer for kinesis-produce-consume

  #233 opened 2 years ago by augustine-p
  2

• Misspelling of letters

  #222 opened 2 years ago by Shelley-China
  1

• Consider adding Reactor Kafka binder sample app

  #248 opened 2 years ago by onobc
  1

• How do we override default adminConfig, ProducerConfig and ConsumerConfigs.

  #246 opened a year ago by voodemsanthosh
  0

• dynamic-destination-source-rabbit - Can you please update ?

  #244 opened a year ago by javaHelper
  0

• Add a sample of consuming and producing messages using function + batch

  #239 opened a year ago by StevenPG
  3

• Add sample "Observability with Spring Boot 3"

  #243 opened a year ago by MikeR13
  0

• SpringCloudStream TestChannelBinderConfiguration Junits not working with Mockito

  #242 opened 2 years ago by srajesh15
  0

• No sample for the Reactive Kafka binder

  #223 opened 2 years ago by rolkhas2
  1

• Reactor kafka samples

  #219 opened 3 years ago by markusherbert
  1

• javax.security.auth.login.LoginException: KrbException: Cannot locate default realm

  #224 opened 2 years ago by ycl1560
  1

• POST requests don't work in the kinesis-produce-consume sample

  #230 opened 2 years ago by augustine-p
  0

• The sample kinesis-produce-consume doesn't run out of the box

  #228 opened 2 years ago by augustine-p
  0

• conditional declarative selecting destination in application.yml file

  #232 opened 2 years ago by vishalrijhwani
  0

• ava.lang.IllegalStateException: Error retrieving state store: prod-id-count-store at org.springframework.cloud.stream.binder.kafka.streams.InteractiveQueryService.lambda$getQueryableStore$0(

  #227 opened 2 years ago by javaHelper
  0

• source-sample/dynamic-destination-source-kafka: Error

  #226 opened 2 years ago by amirensit
  1

• Would be great if you can add sample data to test kafka-streams-samples examples

  #225 opened 2 years ago by javaHelper
  0

• set default clientId throws InstanceAlreadyExistsException

  #187 opened 4 years ago by PrabaharanK
  9

• New example for Kafka Streams split (previous branch)

  #221 opened 3 years ago by benkeil
  2

• Can you please update all tutorials to use latest version of Spring Boot?

  #220 opened 3 years ago by javaHelper
  1

• EmbeddedKafka unit testing a KStream Function with specific Avro

  #201 opened 3 years ago by ddhanak
  0

• spring-cloud-starter-stream-rocketmq: How to configure synchronous sending messages?

  #217 opened 3 years ago by CC-PP
  0

• Since Kafkacat is deprecated, equivalent kcat commands are not working

  #216 opened 3 years ago by javaHelper
  0

• Conversion to Functional Model is Wrong for the Transactional Sample

  #212 opened 3 years ago by garyrussell
  0

• kinesis-produce-consume doesn't run out of the box

  #214 opened 3 years ago by deigote
  2

• Add an RabbitMQ Streams sample

  #213 opened 3 years ago by sabbyanandan
  0

• Upgrade the test-embedded-Kafka sample to JUnit5

  #210 opened 3 years ago by garyrussell
  0

• 'void org.springframework.cloud.stream.binder.kafka.streams.function.KafkaStreamsBindableProxyFactory.populateBindingTargetFactories

  #202 opened 4 years ago by javaHelper
  2

• Create a sample that demonstrates Protobuf message conversion

  #209 opened 3 years ago by vishaldhanani
  0

• Switch "master" to Boot 2.3

  #184 opened 3 years ago by sabbyanandan
  0

• Multi Binder with based on business logic

  #207 opened 4 years ago by voodemsanthosh
  0

• functional composition using kafka data streams binder does not seem to work

  #206 opened 4 years ago by nmorado
  2

• Can't use more than one Consumer

  #200 opened 4 years ago by xwlcn
  1

• Example for Kafka Streams branching with Flux

  #198 opened 4 years ago by benkeil
  2

• Pause Kafka Consumer with Functional Style

  #199 opened 4 years ago by AttitudeL
  7

• ConsumerRecordFactory, testDriver.pipeInput(), testDriver.readOutput() deprecated

  #195 opened 4 years ago by joerajeev
  0

• Add support for NATS/Redis Stream

  #197 opened 4 years ago by uselvvi
  0

• This line is broken

  #185 opened 5 years ago by chocolim
  0

• sample how to handle errors while producing to Kinesis Stream

  #194 opened 4 years ago by jkatnik
  0

• Create a sample for KTable/GlobalKTable actuator health check

  #193 opened 4 years ago by sobychacko
  0

• Can add a sample of Consuming Batches ？

  #191 opened 4 years ago by Bryce-huang
  0

• Spring Cloud Stream Kafka Consumer application doesn't allow adding Supplier

  #189 opened 4 years ago by aniket0788
  0

• No hyperlinks in the README document

  #190 opened 4 years ago by parth-pandit
  3

• serdeError is deprecated

  #188 opened 4 years ago by YohanAlard
  0

• Kafka Streams with RabbitMQ only

  #186 opened 4 years ago by LeoPote
  0

• java.lang.NoClassDefFoundError: org/json/JSONObject

  #181 opened 5 years ago by altfatterz
  1

• kafka-streams-word-count error when running KafkaStreamsWordCountApplicationTests

  #183 opened 5 years ago by gborobio73
  1

• Error when running test-embedded-kafka

  #182 opened 5 years ago by gborobio73
  3

• Provide tests on samples

  #180 opened 5 years ago by nmarquesantos
  1

• add polled-consumer sample for RequeueCurrentMessageException

  #177 opened 5 years ago by xiangeric
  1