confluentinc/kafka-streams-examples

Issues

• Pipeline blocked following corrupted messages

  #524 opened 2 months ago by artignang
  0

• Got Warnings in running WordCount application command

  #517 opened 6 months ago by Vasu2502
  0

• Got warnings on running WordCount Application command from Kafka Docs

  #516 opened 6 months ago by Vasu2502
  0

• Kafka Streams ERROR Could not parse Avro schema

  #482 opened 10 months ago by berbarroso
  0

• Event driven order

  #473 opened a year ago by Asutosh-x-Dash
  0

• Case: 100+ KafkaStreams threads on 3.5k+ topics/partitions with exactly_once_v2 guarantee

  #447 opened a year ago by fu22ybear
  8

• Can't load library when running AnomalyDetectionLambdaExample

  #443 opened 2 years ago by asafm
  2

• Can't find the package io.confluent.examples.streams.avro in src folder

  #440 opened 2 years ago by zzhorse
  1

• Regarding Sum example

  #438 opened 2 years ago by javaHelper
  1

• Is The class of DeserializationExceptionHandler support construct with parameters

  #422 opened 2 years ago by egbertbox
  1

• Do we have example on Kafka Stream Processor API to handle Smart routing case

  #412 opened 2 years ago by xzhan
  1

• How to create Kafka Server with org.apache.kafka:kafka_2.13:test:2.7.1

  #409 opened 2 years ago by abstract-thinking
  1

• Example of Streams-Table join with retry disappeared

  #377 opened 2 years ago by sarwarbhuiyan
  2

• Javadocs for some classes can't be downloaded

  #325 opened 2 years ago by keltik85
  1

• How to suppress window using wall clock time instead of event time in Kafka streams?

  #441 opened 2 years ago by soutong
  1

• Consistency between inventory KTable/Topic and state store "reservedStock" for "shipped" event

  #436 opened 2 years ago by AMLianjun
  1

• Join operation is not working after update to 1.2.0

  #421 opened 3 years ago by alexandraprisecaru
  1

• Do we have example to handle processor exception.

  #420 opened 3 years ago by egbertbox
  0

• Gitpodify so people can easily run the examples with 0 setup

  #415 opened 3 years ago by chuck-confluent
  0

• ditch awaits in docker compose file

  #413 opened 3 years ago by KiaraGrouwstra
  0

• Naming when adding global store

  #410 opened 3 years ago by blacksab
  4

• 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

  #328 opened 4 years ago by larryzhu2018
  3

• GlobalKTablesAndStoresExampleDriver hangs with GlobalKTablesExample

  #406 opened 3 years ago by NyaliaLui
  5

• [BUG] microservices-orders: unknown command "READ" for "ccloud kafka acl create"

  #397 opened 3 years ago by homam86
  3

• Cast error

  #326 opened 3 years ago by antonjos
  1

• Starting OrderServiceTest in IntelliJ causes AccessDeniedException for 3 of the 4 Tests

  #321 opened 3 years ago by keltik85
  2

• PageView Demo requires more configuration properties to be used within secure environment

  #327 opened 5 years ago by kamir
  1

• Example of using kafka-streams-protobuf-serde

  #374 opened 4 years ago by aivinog1
  2

• Rquest to enhance the Music app example with features from KIP-535

  #349 opened 4 years ago by cdadia
  0

• Dynamic subscription source topic

  #291 opened 3 years ago by imperio-wxm
  1

• Sliding Window without join

  #292 opened 3 years ago by bdun1013
  1

• Extract KafkaEmbeded to a dedicated test lib

  #317 opened 3 years ago by danielpetisme
  1

• Docker-compose fails: ERROR: manifest for confluentinc/cp-zookeeper:5.4.x-latest not found: manifest unknown

  #319 opened 3 years ago by starkcoffee
  4

• when i try to delete specific topic it crash the Kafka and suddenly stopped why ? ?

  #323 opened 3 years ago by zeinabkamel
  2

• Global store does not work in Processor API

  #351 opened 3 years ago by hitenny
  1

• how to Packaging and running the Application Examples

  #399 opened 3 years ago by aibama
  1

• DeduplicationTransformer example only supports 1 partition

  #396 opened 3 years ago by jomach
  2

• Replace io.confluent.kafka.serializers.AbstractKafkaAvroSerDeConfig with AbstractKafkaSchemaSerDeConfig

  #336 opened 4 years ago by ybyzek
  16

• Punctuate being invoked in Transformer at Irregular intervals

  #316 opened 4 years ago by piyuverma
  1

• Could not find any ccs-kafka artifacts

  #362 opened 4 years ago by sanjaygarde
  7

• Question about KafkaMusic's top five songs aggregator

  #380 opened 4 years ago by benissimo
  6

• Kafka Stream cannot join multiple KTable

  #368 opened 4 years ago by cuongndc9
  0

• bug cannot overwrite log.segment.bytes value ChangeLog kafka streams internal topics

  #303 opened 4 years ago by FridMehdi
  0

• Kafka Streams app resets consumer offset for a single partition

  #365 opened 4 years ago by udesaiitrs
  1

• Global Store Adding change log topic

  #322 opened 4 years ago by saggarsunil
  7

• Kafka streams errors out "Missing source topic" after upgrading from 1.0.0

  #357 opened 4 years ago by prasanna-palle
  1

• Method of metadataForKey in Kafka Streams gives wrong information for multiple instances of application connected to the same group

  #352 opened 4 years ago by victorchicu
  2

• Can not find class under package io.confluent.examples.streams.avro

  #337 opened 5 years ago by iXingo
  2

• Can not export Prometheus metrics

  #295 opened 5 years ago by Josca
  1

• How to stop kstream app on kafka disconnection

  #294 opened 5 years ago by Josca
  2