TechPrimers/spring-boot-kafka-producer-example

Stars
129
Rank 279,262 (Top 6 %)
Language
Java
Created over 6 years ago
Updated over 2 years ago

TechPrimers/spring-boot-kafka-producer-example

TechPrimers

There are no reviews yet. Be the first to send feedback to the community and the maintainers!

Spring Boot Kafka Producer Example

Spring Boot with Kafka Producer Example

This Project covers how to use Spring Boot with Spring Kafka to Publish JSON/String message to a Kafka topic

Start Zookeeper

bin/zookeeper-server-start.sh config/zookeeper.properties

Start Kafka Server

bin/kafka-server-start.sh config/server.properties

Create Kafka Topic

bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic Kafka_Example

Consume from the Kafka Topic via Console

bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic Kafka_Example --from-beginning

Publish message via WebService

http://localhost:8081/kafka/publish/Sam
http://localhost:8081/kafka/publish/Peter

learning-path-spring-boot-microservices

Curated path for learning Spring Boot & Microservices based on published videos in TechPrimers

spring-security-oauth-example

This repo has example for Spring Boot integration with Spring Security using OAuth2

jwt-security-example

Spring Boot with Spring Security using JWT

spring-batch-example-1

Spring Boot with Spring Batch Example 1 (Load CSV to DB)

stock-price-viewer-microservices-part1

Spring Cloud services with 5 microservices - End to End Example

spring-security-db-example

Spring Security in a Spring Boot Application with Authentication and Authorization using DB

spring-boot-kafka-consumer-example

Spring Boot Kafka Consumer Example

spring-boot-graphql-query-example

Spring Boot with GraphQL Query Example

jenkins-example

Example project with Groovy based Jenkins Pipeline (Jenkinsfile)

learning-path-system-design

Curated path for learning System Design based on published videos in TechPrimers

whats-your-architecture

"What's your Architecture?" is a series of architecture and design challenges to voice out the opinions of the TechPrimers community members.

spring-security-oauth-mysql-example

Spring Security using OAuth2 in Spring Boot using MySQL

k8s-spring-boot-example

Kubernetes Spring Boot Example commands

spring-boot-websocket-example

WebSocket example using Spring Boot

kafka-streams-microservices-example

End to End project for Kafka Streams using Spring Cloud Kafka streams

docker-mysql-spring-boot-example

Spring Boot on Docker connecting to MySQL Docker container

spring-boot-mongodb-example

Spring Boot Using Spring Data MongoDB Example

java-blockchain-example

Java BlockChain Example

spring-cloud-eureka-hystrix-zuul-example

Spring Cloud Eureka, Hystrix and Zuul Example

spring-boot-swagger-example

This repo has example for Spring Boot integration with Swagger 2

techprimers.github.io

Source code for http://techprimers.github.io

core-nlp-example

Natural Language Processing Example using Stanford's Core NLP Java Library

spring-data-rest-jpa-example

Spring Data REST and JPA Example

spring-security-ldap-example

Spring Boot using Spring Security and LDAP

stock-price-viewer-microservices-part2-final

spring-boot-soap-example

Spring WebServices (SOAP) using Spring Boot Example

spring-data-elastic-example-1

Spring Data Elastic Search with REST

spring-cloud-kubernetes-config-example

Spring Cloud Kubernetes Config example

spring-redis-example

spring-jpa-hibernate-mysql-example

Spring Data JPA with Hibernate using MySql Example

grpc-spring-boot-example

Spring Boot gRPC Example

spring-boot-mybatis-mysql-example

aws-cloud-formation-templates

AWS CloudFormation Templates

spring-boot-1.5-micrometer-prometheus-example

Spring Boot 1.5 with Micrometer and Prometheus

spring-boot-neo4j-example-1

Spring Boot and Neo4J using Spring Data Neo4J Query example

spent

Open Source Project for tracking all your spends based on your Bank Statements

k8s-the-easy-way

Tips and Tricks on Kubernetes

spring-cloud-kubernetes-discovery-client-example

Spring Cloud Kubernetes Discovery Client Example

aws-beanstalk-example-2

AWS Bean Stalk Example for CI CD

test-controller-example

spring-boot-facebook-login-example

Spring Boot using OAuth2 and Facebook Login example

spring-boot-mysql-example

Spring Boot Example with MySql Connectivity using JPA

jenkins-pipeline-cucumber-example

Jenkins Pipeline cucumber example

spring-jpa-hibernate-one-to-many-example

OneToMany Mapping example in Hibernate using Spring JPA in MySql

spring-cloud-eureka-and-hystrix-example

Spring Cloud Eureka and Hystrix Example

spring-ehcache-example

Spring Cache using EhCache example in a Spring Boot Application

spring-boot-https-example

Spring Boot with HTTPS Example

restwebservice-vertx-example

Restful Webservice using Vertx

spring-cloud-function-aws-example

Spring Cloud Function using AWS Adapter in AWS Lambda

skaffold-spring-boot-example

Skaffold Spring Boot Example

url-shortener-example

URL Shortener using Spring Boot and Spring Data Redis

reactive-mongo-example-1

standalone-spring-boot-activemq-example

spring-boot-lazy-init-example

Spring Boot 2.2+ Lazy Initialization Example

saga-choreography-example

Saga Choregraphy Example using Spring Boot, DynamoDB and SQS on EKS

spring-boot-jaeger-example

Jaeger with Spring Boot example for Distributed log tracing

resilience4j-circuitbreaker

Spring Boot 3 Resilience4J example

structural-design-pattern-example

Structural Design Patterns in Java Examples

spring-jpa-hibernate-many-to-one-example

ManyToOne Mapping example in Hibernate using Spring JPA in MySql

ratelimiter-example

Example repo for Rate Limiter using Spring Cloud Gateway

eks-kinesis-example

Stream Processing Example using Spring Boot, Spring Cloud Stream, EKS, Kinesis Data Streams, Kinesis Data Analytics

spring-security-example

spring-data-elastic-example-2

Spring Data Elastic Search with Query DSL

java9-modular-example

Java 9 Modules Example - Modular Programming

inmemory-spring-boot-activemq-example

Spring Boot using InMemory ActiveMQ Example

spring-jpa-hibernate-one-to-one-example

OneToOne Mapping example in Hibernate using Spring JPA in MySql

spring-boot-profiles-example

Spring Boot Profiles example

spring-boot-config-server-example

Spring Boot using Spring Cloud Config Server

spring-integration-example-1

Spring Boot with Spring Integration Example

spring-cloud-function-example

Spring Cloud Function example

aws-lambda-api-java-example

AWS Lambda API Java Example using API Gateway trigger

game-of-pods-kodekloud-challenge

Game of Pods KodeKloud Challenge

spring-cloud-gateway-example-1

Spring Cloud Gateway with Hystrix example

spring-data-elastic-example-3

Spring Data Elastic Search with REST and JPA

spring-boot-mybatis-mysql-example-2

python-containerize-lambda

Containers on lambda using Python

cicd-jenkins-example

CICD Jenkins example using Pivotal Web Services / Pivotal Cloud Foundry

spring-cloud-aws-example-1

Spring Cloud AWS with SQS and ElastiCache for Redis

spring-boot-actuator-example

Spring Boot using Actuators

gradle-custom-plugin-example

Gradle Custom Plugin Example

rest-hateoas-example

Spring Boot HATEOAS Example for REST

functional-programming

rule-engine-example-1

Simple Rule Engine in Java

spring-boot-cloud-foundry-example

Spring Boot Example which is deployed in Cloud Foundry

transactionality-demo

Transactionality Example in Spring Boot

creational-design-patterns-example

Creational Design Patterns in Java Examples

cloud-native-meetup-observability-demo

Demo resources used in Observability meetup (Cloud Native Bangalore) on Jan 18, 2020

micronaut-service-discovery-example

Micronaut Service Discovery Example with Eureka

session-mgmt-example

Session Management using Spring Session Redis in Spring Boot

k8s-readiness-liveness-example

Readiness and Liveness probe example ymls

iterm2-setup

Iterm2 Setup Details

spring-cloud-sleuth-example

Distributed Log Traceability using Spring Cloud Sleuth

spring-data-elastic-example-4

Spring Data Elastic Search with Delete Index

k8s-secrets

Kubernetes Secrets

hugo-example

Hugo Example site using Hyde theme

terraform-primer

Terraform Primer Series

junit5-example

minikube-installation-macbook-pro

Steps for installing minikube on macbook pro 2018

spark-java-example

Running a simple Java program in Spark

standalone-elastic-example

Accessing Standalone Elastic Search Instance from a Spring Boot/MVC application