friendbear / springboot-kafka-real-world-project Goto Github PK
View Code? Open in Web Editor NEWSpring Boot Kafka Real-World Project Tutorial - Spring Boot Kafka Microservices.
Spring Boot Kafka Real-World Project Tutorial - Spring Boot Kafka Microservices.
Kafka: 3.2-2.3
Java: 17
spring.kafka.producer.bootstrap-servers: localhost:9092
spring.kafka.producer.key-serializer: org.apache.kafka.common.serialization.StringDeserializer
spring.kafka.producer.value-serializer: org.apache.kafka.common.serialization.StringDeserializer
spring.kafka.producer.linger-ms: 20
spring.kafka.producer.batch-size: 92000
spring.kafka.producer.compression-type: snappy
2022-07-14T20:23:41.945+09:00 INFO 3185 --- [rce-events-[]-0] o.a.k.clients.producer.KafkaProducer : [Producer clientId=producer-1825] Closing the Kafka producer with timeoutMillis = 0 ms.
2022-07-14T20:23:41.945+09:00 INFO 3185 --- [rce-events-[]-0] org.apache.kafka.common.metrics.Metrics : Metrics scheduler closed
2022-07-14T20:23:41.945+09:00 INFO 3185 --- [rce-events-[]-0] org.apache.kafka.common.metrics.Metrics : Closing reporter org.apache.kafka.common.metrics.JmxReporter
2022-07-14T20:23:41.945+09:00 INFO 3185 --- [rce-events-[]-0] org.apache.kafka.common.metrics.Metrics : Metrics reporters closed
2022-07-14T20:23:41.945+09:00 INFO 3185 --- [rce-events-[]-0] o.a.kafka.common.utils.AppInfoParser : App info kafka.producer for producer-1825 unregistered
2022-07-14T20:23:41.945+09:00 WARN 3185 --- [rce-events-[]-0] c.launchdarkly.eventsource.EventSource : Caught unexpected error from EventHandler: org.apache.kafka.common.KafkaException: Failed to construct kafka producer
2022-07-14T20:23:41.945+09:00 INFO 3185 --- [rce-events-[]-0] b.l.s.kafka.WikimediaChangesProducer : event data -> MessageEvent(eventName=message,data={"$schema":"/mediawiki/recentchange/1.0.0","meta":{"uri":"https://en.wikipedia.org/wiki/Deux-Montagnes_station","request_id":"0f1fd249-67eb-4c76-b8a1-1a0b5b929056","id":"12398b1b-cc0a-4b12-8988-789e952d45b0","dt":"2022-07-14T11:23:40Z","domain":"en.wikipedia.org","stream":"mediawiki.recentchange","topic":"eqiad.mediawiki.recentchange","partition":0,"offset":4005031264},"id":1526273052,"type":"edit","namespace":0,"title":"Deux-Montagnes station","comment":"Adding local [[Wikipedia:Short description|short description]]: \"Railway station in Quebec, Canada\", overriding Wikidata description \"railway station in Canada\"","timestamp":1657797820,"user":"ThadeusOfNazereth","bot":false,"minor":false,"length":{"old":6183,"new":6239},"revision":{"old":1050950293,"new":1098143094},"server_url":"https://en.wikipedia.org","server_name":"en.wikipedia.org","server_script_path":"/w","wiki":"enwiki","parsedcomment":"Adding local <a href=\"/wiki/Wikipedia:Short_description\" title=\"Wikipedia:Short description\">short description</a>: "Railway station in Quebec, Canada", overriding Wikidata description "railway station in Canada""},id=[{"topic":"eqiad.mediawiki.recentchange","partition":0,"timestamp":1657797820001},{"topic":"codfw.mediawiki.recentchange","partition":0,"offset":-1}],origin=https://stream.wikimedia.org/v2/stream/recentchange)
2022-07-14T20:23:41.945+09:00 INFO 3185 --- [rce-events-[]-0] o.a.k.clients.producer.ProducerConfig : ProducerConfig values:
acks = -1
batch.size = 92000
bootstrap.servers = [localhost:9092]
buffer.memory = 33554432
client.dns.lookup = use_all_dns_ips
client.id = producer-1826
compression.type = snappy
connections.max.idle.ms = 540000
delivery.timeout.ms = 120000
enable.idempotence = true
interceptor.classes = []
key.serializer = class org.apache.kafka.common.serialization.StringDeserializer
linger.ms = 0
max.block.ms = 60000
max.in.flight.requests.per.connection = 5
max.request.size = 1048576
metadata.max.age.ms = 300000
metadata.max.idle.ms = 300000
metric.reporters = []
metrics.num.samples = 2
metrics.recording.level = INFO
metrics.sample.window.ms = 30000
partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner
receive.buffer.bytes = 32768
reconnect.backoff.max.ms = 1000
reconnect.backoff.ms = 50
request.timeout.ms = 30000
retries = 2147483647
retry.backoff.ms = 100
sasl.client.callback.handler.class = null
sasl.jaas.config = null
sasl.kerberos.kinit.cmd = /usr/bin/kinit
sasl.kerberos.min.time.before.relogin = 60000
sasl.kerberos.service.name = null
sasl.kerberos.ticket.renew.jitter = 0.05
sasl.kerberos.ticket.renew.window.factor = 0.8
sasl.login.callback.handler.class = null
sasl.login.class = null
sasl.login.connect.timeout.ms = null
sasl.login.read.timeout.ms = null
sasl.login.refresh.buffer.seconds = 300
sasl.login.refresh.min.period.seconds = 60
sasl.login.refresh.window.factor = 0.8
sasl.login.refresh.window.jitter = 0.05
sasl.login.retry.backoff.max.ms = 10000
sasl.login.retry.backoff.ms = 100
sasl.mechanism = GSSAPI
sasl.oauthbearer.clock.skew.seconds = 30
sasl.oauthbearer.expected.audience = null
sasl.oauthbearer.expected.issuer = null
sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000
sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000
sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100
sasl.oauthbearer.jwks.endpoint.url = null
sasl.oauthbearer.scope.claim.name = scope
sasl.oauthbearer.sub.claim.name = sub
sasl.oauthbearer.token.endpoint.url = null
security.protocol = PLAINTEXT
security.providers = null
send.buffer.bytes = 131072
socket.connection.setup.timeout.max.ms = 30000
socket.connection.setup.timeout.ms = 10000
ssl.cipher.suites = null
ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
ssl.endpoint.identification.algorithm = https
ssl.engine.factory.class = null
ssl.key.password = null
ssl.keymanager.algorithm = SunX509
ssl.keystore.certificate.chain = null
ssl.keystore.key = null
ssl.keystore.location = null
ssl.keystore.password = null
ssl.keystore.type = JKS
ssl.protocol = TLSv1.3
ssl.provider = null
ssl.secure.random.implementation = null
ssl.trustmanager.algorithm = PKIX
ssl.truststore.certificates = null
ssl.truststore.location = null
ssl.truststore.password = null
ssl.truststore.type = JKS
transaction.timeout.ms = 60000
transactional.id = null
value.serializer = class org.apache.kafka.common.serialization.StringDeserializer
2022-07-14T20:23:41.945+09:00 INFO 3185 --- [rce-events-[]-0] o.a.k.clients.producer.KafkaProducer : [Producer clientId=producer-1826] Closing the Kafka producer with timeoutMillis = 0 ms.
2022-07-14T20:23:41.945+09:00 INFO 3185 --- [rce-events-[]-0] org.apache.kafka.common.metrics.Metrics : Metrics scheduler closed
2022-07-14T20:23:41.945+09:00 INFO 3185 --- [rce-events-[]-0] org.apache.kafka.common.metrics.Metrics : Closing reporter org.apache.kafka.common.metrics.JmxReporter
2022-07-14T20:23:41.945+09:00 INFO 3185 --- [rce-events-[]-0] org.apache.kafka.common.metrics.Metrics : Metrics reporters closed
2022-07-14T20:23:41.945+09:00 INFO 3185 --- [rce-events-[]-0] o.a.kafka.common.utils.AppInfoParser : App info kafka.producer for producer-1826 unregistered
2022-07-14T20:23:41.945+09:00 WARN 3185 --- [rce-events-[]-0] c.launchdarkly.eventsource.EventSource : Caught unexpected error from EventHandler: org.apache.kafka.common.KafkaException: Failed to construct kafka producer
A declarative, efficient, and flexible JavaScript library for building user interfaces.
๐ Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
An Open Source Machine Learning Framework for Everyone
The Web framework for perfectionists with deadlines.
A PHP framework for web artisans
Bring data to life with SVG, Canvas and HTML. ๐๐๐
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
Some thing interesting about web. New door for the world.
A server is a program made to process requests and deliver data to clients.
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
Some thing interesting about visualization, use data art
Some thing interesting about game, make everyone happy.
We are working to build community through open source technology. NB: members must have two-factor auth.
Open source projects and samples from Microsoft.
Google โค๏ธ Open Source for everyone.
Alibaba Open Source for everyone
Data-Driven Documents codes.
China tencent open source team.