confluentinc/kafka-streams-examples: Demo applications and code examples for Apache Kafka's Streams API.

2049
STARS
316
WATCHERS
1051
FORKS
25
ISSUES

kafka-streams-examples's Language Statistics

confluentinc's Other Repos

Star history of kafka-streams-examples
Issue history of kafka-streams-examples

kafka-streams-examples Recent Issues

Issue Title State Comments Created Date Updated Date Closed Date
Consistency between inventory KTable/Topic and state store "reservedStock" for "shipped" event open 1 2022-07-19 2022-09-17 -
Is The class of DeserializationExceptionHandler support construct with parameters open 0 2022-03-31 2022-09-17 -
Join operation is not working after update to 1.2.0 closed 1 2022-03-21 2022-09-17 2022-03-28
Do we have example to handle processor exception. open 0 2022-03-16 2022-09-17 -
Gitpodify so people can easily run the examples with 0 setup open 0 2022-01-10 2022-09-17 -
ditch awaits in docker compose file open 0 2021-12-23 2022-09-30 -
Do we have example on Kafka Stream Processor API to handle Smart routing case open 1 2021-12-08 2022-09-28 -
Naming when adding global store closed 4 2021-11-24 2022-09-24 2021-12-03
How to create Kafka Server with org.apache.kafka:kafka_2.13:test:2.7.1 open 0 2021-11-16 2022-09-17 -
GlobalKTablesAndStoresExampleDriver hangs with GlobalKTablesExample closed 5 2021-10-06 2022-09-28 2021-10-14
how to Packaging and running the Application Examples closed 1 2021-08-09 2022-09-29 2021-08-15
[BUG] microservices-orders: unknown command "READ" for "ccloud kafka acl create" closed 3 2021-08-01 2022-09-17 2021-08-21
DeduplicationTransformer example only supports 1 partition closed 2 2021-07-29 2022-09-17 2021-08-03
Question about KafkaMusic's top five songs aggregator closed 6 2021-03-06 2022-09-17 2021-03-09
Example of Streams-Table join with retry disappeared open 2 2021-02-16 2022-09-17 -
Example of using kafka-streams-protobuf-serde open 2 2021-02-04 2022-09-17 -
Could not find any ccs-kafka artifacts closed 7 2020-09-29 2022-09-17 2021-03-23
Global store does not work in Processor API closed 1 2020-07-30 2022-09-30 2021-08-15
Rquest to enhance the Music app example with features from KIP-535 open 0 2020-07-23 2022-09-25 -
Replace io.confluent.kafka.serializers.AbstractKafkaAvroSerDeConfig with AbstractKafkaSchemaSerDeConfig closed 16 2020-05-05 2022-09-28 2021-04-21
pull access denied for placeholder/confluentinc/cp-base-new, repository does not exist or may require 'docker login': denied: requested access to the resource is denied closed 3 2020-03-25 2022-09-17 2020-12-27
PageView Demo requires more configuration properties to be used within secure environment open 1 2020-03-22 2022-09-17 -
Cast error closed 1 2020-03-19 2022-01-12 2021-08-16
Javadocs for some classes can't be downloaded open 1 2020-03-12 2022-09-17 -
when i try to delete specific topic it crash the Kafka and suddenly stopped why ? ? closed 2 2020-03-05 2022-09-17 2021-08-15
Starting OrderServiceTest in IntelliJ causes AccessDeniedException for 3 of the 4 Tests closed 2 2020-02-27 2022-09-17 2021-08-15
Docker-compose fails: ERROR: manifest for confluentinc/cp-zookeeper:5.4.x-latest not found: manifest unknown closed 4 2020-02-09 2022-09-17 2021-08-15
Extract KafkaEmbeded to a dedicated test lib closed 1 2020-01-20 2022-09-17 2021-08-15
Punctuate being invoked in Transformer at Irregular intervals closed 1 2020-01-16 2022-09-17 2021-03-24
Sliding Window without join closed 1 2019-09-27 2022-09-17 2021-08-15
Dynamic subscription source topic closed 1 2019-09-11 2022-09-17 2021-08-15
Unable to start kafka, since replication factor not set closed 1 2019-07-26 2022-09-24 2021-08-15
PXT7972TA13MAC:kafka-streams-examples user$ docker-compose up closed 2 2019-06-23 2022-09-17 2021-08-15
Add example for subscribing to multiple topics open 1 2019-06-11 2022-09-25 -
Failed to build schema-registry closed 1 2019-04-02 2022-09-24 2021-08-15
Build project standalone closed 0 2019-03-15 2022-09-17 2021-08-15
Deleting topics throws exception closed 11 2019-01-22 2022-09-25 2019-01-23
Consumed class has moved to org.apache.kafka.streams.kstream.Consumed closed 1 2019-01-18 2022-09-17 2021-08-15
Error building repo closed 2 2018-11-14 2022-01-12 2021-08-15
KafkaStreams : start method too long closed 7 2018-10-23 2022-09-30 2021-08-15
Question: Adding example for reordering out of order messages open 9 2018-10-17 2022-09-30 -
Kafka Connect distributed and Connector failures closed 2 2018-09-06 2022-09-17 2021-08-15
Microservices: ValidationsAggregatorService.java failure (DEVX-244) closed 1 2018-08-30 2022-09-26 2021-08-15
Cancelling Scheduled Punctuator after a single iteration closed 7 2018-05-09 2022-09-17 2021-08-15
Kafka Stream Query to fetch song details where song id > 10 open 1 2018-04-02 2022-09-17 -
Filter Predicate not gettting called closed 2 2018-01-31 2022-09-27 2021-08-15
Inner join by key where key is GenericRecord closed 3 2017-11-29 2022-09-17 2021-08-15
Encapsulate EmbeddedSingleNodeKafkaCluster in a seperately-available maven/gradle/sbt dep closed 12 2017-11-10 2022-09-30 2021-08-15