{"payload":{"pageCount":1,"repositories":[{"type":"Public","name":"jikkou","owner":"streamthoughts","isFork":false,"description":"The Open source Resource as Code framework for Apache Kafka","allTopics":["yaml","automation","kafka","tool","acl","kafka-topic","kafka-manager","kafka-cluster","cluster-manager","datamesh","git-ops"],"primaryLanguage":{"name":"Java","color":"#b07219"},"pullRequestCount":8,"issueCount":17,"starsCount":165,"forksCount":20,"license":"Apache License 2.0","participation":null,"lastUpdated":{"hasBeenPushedTo":true,"timestamp":"2024-06-05T03:11:03.777Z"}},{"type":"Public","name":"kafka-connect-file-pulse","owner":"streamthoughts","isFork":false,"description":"🔗 A multipurpose Kafka Connect connector that makes it easy to parse, transform and stream any file, in any format, into Apache Kafka","allTopics":["etl","google-cloud","kafka-connect","kafka-producer","azure-storage","amazon-s3","grok-filters","file-streaming","csv","kafka","avro","xml","kafka-connector"],"primaryLanguage":{"name":"Java","color":"#b07219"},"pullRequestCount":7,"issueCount":18,"starsCount":308,"forksCount":60,"license":"Apache License 2.0","participation":null,"lastUpdated":{"hasBeenPushedTo":true,"timestamp":"2024-05-24T14:15:51.896Z"}},{"type":"Public","name":"jikkou-extension-provider-file","owner":"streamthoughts","isFork":false,"description":"Jikkou Extension Provider for File","allTopics":[],"primaryLanguage":{"name":"Java","color":"#b07219"},"pullRequestCount":6,"issueCount":0,"starsCount":0,"forksCount":0,"license":"Apache License 2.0","participation":null,"lastUpdated":{"hasBeenPushedTo":true,"timestamp":"2024-02-14T16:24:41.171Z"}},{"type":"Public","name":"kafka-consumer-partition-assignor","owner":"streamthoughts","isFork":false,"description":"This project contains examples to implement a custom PartitionAssignor for Apache Kafka consumer-client.","allTopics":[],"primaryLanguage":{"name":"Java","color":"#b07219"},"pullRequestCount":1,"issueCount":0,"starsCount":12,"forksCount":9,"license":"Apache License 2.0","participation":null,"lastUpdated":{"hasBeenPushedTo":true,"timestamp":"2023-09-05T22:01:58.495Z"}},{"type":"Public","name":"demo-kafka-streams-scottify","owner":"streamthoughts","isFork":false,"description":"Scottify is the official media services provider of Starfleet 🖖","allTopics":["demo","kafka","kafka-streams","apachekafka","azkarra-streams"],"primaryLanguage":{"name":"Java","color":"#b07219"},"pullRequestCount":3,"issueCount":0,"starsCount":3,"forksCount":1,"license":"Apache License 2.0","participation":null,"lastUpdated":{"hasBeenPushedTo":true,"timestamp":"2022-11-16T00:45:46.954Z"}},{"type":"Public","name":"kc4streams","owner":"streamthoughts","isFork":false,"description":"A collection of common utilities and reusable classes for Kafka Streams applications.","allTopics":["java","kafka","apache-kafka","kafka-streams"],"primaryLanguage":{"name":"Java","color":"#b07219"},"pullRequestCount":0,"issueCount":0,"starsCount":6,"forksCount":1,"license":"Apache License 2.0","participation":null,"lastUpdated":{"hasBeenPushedTo":true,"timestamp":"2022-02-22T08:44:39.340Z"}},{"type":"Public","name":"kafka-streams-examples","owner":"streamthoughts","isFork":false,"description":"This project contains code examples that demonstrate how to use the KafkaStreams Streams DSL and Processor API.","allTopics":["java","kafka","kafka-streams","kafka-streams-examples"],"primaryLanguage":{"name":"Java","color":"#b07219"},"pullRequestCount":3,"issueCount":0,"starsCount":1,"forksCount":3,"license":"Apache License 2.0","participation":null,"lastUpdated":{"hasBeenPushedTo":true,"timestamp":"2022-01-09T17:06:05.873Z"}},{"type":"Public","name":"kafka-connect-client","owner":"streamthoughts","isFork":false,"description":"Java client library for Apache Kafka Connect REST Interface","allTopics":["java","kafka","http-client","kafka-connect","kafka-client"],"primaryLanguage":{"name":"Java","color":"#b07219"},"pullRequestCount":0,"issueCount":5,"starsCount":6,"forksCount":4,"license":"Apache License 2.0","participation":null,"lastUpdated":{"hasBeenPushedTo":true,"timestamp":"2021-04-12T07:20:38.728Z"}},{"type":"Public","name":"kafka-connect-transform-grok","owner":"streamthoughts","isFork":false,"description":"Grok Expression Transform for Kafka Connect.","allTopics":["kafka-connect","grok-parser","apache-kafka","grok-patterns"],"primaryLanguage":{"name":"Java","color":"#b07219"},"pullRequestCount":0,"issueCount":2,"starsCount":16,"forksCount":5,"license":"Apache License 2.0","participation":null,"lastUpdated":{"hasBeenPushedTo":true,"timestamp":"2021-02-08T15:29:56.100Z"}},{"type":"Public","name":"apache-pulsar-cheat-sheet","owner":"streamthoughts","isFork":false,"description":"This cheat sheet is filled with some handy tips, commands and code snippets to get you streaming data using Apache Pulsar in no time!","allTopics":["java","cheat-sheets","apache-pulsar","pulsar-client","pulsar-functions","pulsar-sql"],"primaryLanguage":{"name":"Java","color":"#b07219"},"pullRequestCount":0,"issueCount":0,"starsCount":28,"forksCount":8,"license":null,"participation":null,"lastUpdated":{"hasBeenPushedTo":true,"timestamp":"2020-11-04T21:33:06.463Z"}},{"type":"Public","name":"azkarra-streaming-count","owner":"streamthoughts","isFork":false,"description":"This project demonstrates how to build and containerize a Kafka Streams ap using Akzarra and Jib","allTopics":["docker","apache-kafka","kafka-streams","jib","azkarra-streams"],"primaryLanguage":{"name":"Java","color":"#b07219"},"pullRequestCount":0,"issueCount":0,"starsCount":1,"forksCount":1,"license":null,"participation":null,"lastUpdated":{"hasBeenPushedTo":true,"timestamp":"2020-06-22T11:20:10.660Z"}},{"type":"Public","name":"demo-twitter-ksqldb-clickhouse","owner":"streamthoughts","isFork":false,"description":"Demonstration Project : Fast Data Analytic platform with Clickhouse, Apache Kafka and ksqlDB","allTopics":["analytics","clickhouse","stream-processing","kafka-connect","apache-kafka","demo-app","ksqldb"],"primaryLanguage":{"name":"Java","color":"#b07219"},"pullRequestCount":0,"issueCount":0,"starsCount":19,"forksCount":13,"license":null,"participation":null,"lastUpdated":{"hasBeenPushedTo":true,"timestamp":"2020-05-25T15:16:52.182Z"}},{"type":"Public","name":"spark-streaming-examples","owner":"streamthoughts","isFork":false,"description":"This project contains simple code skeleton for developing a Spark Streaming application using Kafka integration.","allTopics":[],"primaryLanguage":{"name":"Java","color":"#b07219"},"pullRequestCount":0,"issueCount":0,"starsCount":1,"forksCount":1,"license":null,"participation":null,"lastUpdated":{"hasBeenPushedTo":true,"timestamp":"2019-11-06T20:00:54.397Z"}},{"type":"Public","name":"pulsar-quickstart-java","owner":"streamthoughts","isFork":false,"description":"This project demonstrates how to write simple producers and consumers for Apache Pulsar","allTopics":["apache-pulsar","java","pulsar","consumers"],"primaryLanguage":{"name":"Java","color":"#b07219"},"pullRequestCount":0,"issueCount":0,"starsCount":3,"forksCount":2,"license":"Apache License 2.0","participation":null,"lastUpdated":{"hasBeenPushedTo":true,"timestamp":"2019-10-22T18:36:11.774Z"}}],"repositoryCount":14,"userInfo":null,"searchable":true,"definitions":[],"typeFilters":[{"id":"all","text":"All"},{"id":"public","text":"Public"},{"id":"source","text":"Sources"},{"id":"fork","text":"Forks"},{"id":"archived","text":"Archived"},{"id":"template","text":"Templates"}],"compactMode":false},"title":"Repositories"}