Neil Buesing
@nbuesing.bsky.social
Kafka architect & developer, Java developer
September 14, 2025 at 10:18 PM
@bengamble7.bsky.social - Watching @intellijidea.com's "Valhalla Nullness Emotion" and the talk about Collections of value classes (needing workaround to runtime erasure). Gets me to our conversations - what would it be like if Java 5 (1.5) accepted a VM change and didn't do generic erasures?
June 3, 2025 at 12:59 PM
@bengamble7.bsky.social - Watching @intellijidea.com's "Valhalla Nullness Emotion" and the talk about Collections of value classes (needing workaround to runtime erasure). Gets me to our conversations - what would it be like if Java 5 (1.5) accepted a VM change and didn't do generic erasures?
Enjoying @intellijidea.com's Conference 2025 (not able to watch most of it live, but catching a session right now).
Super excited that Wrapper Classes will be Value Classes. Every time I see/hear about this. I've never liked auto-boxing; this is a major improvement.
Thanks, Rémi Forax.
Super excited that Wrapper Classes will be Value Classes. Every time I see/hear about this. I've never liked auto-boxing; this is a major improvement.
Thanks, Rémi Forax.
June 3, 2025 at 12:35 PM
Enjoying @intellijidea.com's Conference 2025 (not able to watch most of it live, but catching a session right now).
Super excited that Wrapper Classes will be Value Classes. Every time I see/hear about this. I've never liked auto-boxing; this is a major improvement.
Thanks, Rémi Forax.
Super excited that Wrapper Classes will be Value Classes. Every time I see/hear about this. I've never liked auto-boxing; this is a major improvement.
Thanks, Rémi Forax.
May 20, 2025 at 4:39 PM
Looking forward to @sharatchander.bsky.social 's Keynote. Then, looking forward to hearing @gamussa.dev talking about Kafka and the Schema Registry, and then more!
Java, Kafka, @kafkastreams.bsky.social, & @intellijidea.com - that's my tech stack!
lp.jetbrains.com/intellij-ide...
@jetbrains.com
Java, Kafka, @kafkastreams.bsky.social, & @intellijidea.com - that's my tech stack!
lp.jetbrains.com/intellij-ide...
@jetbrains.com
IntelliJ IDEA Conf 2025 | June 3-4, 2025
We invite you to join us for IntelliJ IDEA Conf 2025 and gain insights from industry leaders and experts.
lp.jetbrains.com
April 22, 2025 at 3:52 PM
Looking forward to @sharatchander.bsky.social 's Keynote. Then, looking forward to hearing @gamussa.dev talking about Kafka and the Schema Registry, and then more!
Java, Kafka, @kafkastreams.bsky.social, & @intellijidea.com - that's my tech stack!
lp.jetbrains.com/intellij-ide...
@jetbrains.com
Java, Kafka, @kafkastreams.bsky.social, & @intellijidea.com - that's my tech stack!
lp.jetbrains.com/intellij-ide...
@jetbrains.com
Apache Kafka Meetup here at Target Plaza Commons.
Thanks @confluent.io and Target.
@sandonjacobs.bsky.social - great talk on queues (didn’t mean to use that word) for Kafka
Now Target presenting 👏
Thanks @confluent.io and Target.
@sandonjacobs.bsky.social - great talk on queues (didn’t mean to use that word) for Kafka
Now Target presenting 👏
April 8, 2025 at 11:46 PM
Apache Kafka Meetup here at Target Plaza Commons.
Thanks @confluent.io and Target.
@sandonjacobs.bsky.social - great talk on queues (didn’t mean to use that word) for Kafka
Now Target presenting 👏
Thanks @confluent.io and Target.
@sandonjacobs.bsky.social - great talk on queues (didn’t mean to use that word) for Kafka
Now Target presenting 👏
I think meeup.com is a great service & I have always felt their pricing model being based on organizations vs those attending made sense. If they now want to limit attendance viewership to an attendee paid tier model; I'm ok with that too. But the constant nagware/pop-up? annoying and off-putting.
April 3, 2025 at 7:39 PM
I think meeup.com is a great service & I have always felt their pricing model being based on organizations vs those attending made sense. If they now want to limit attendance viewership to an attendee paid tier model; I'm ok with that too. But the constant nagware/pop-up? annoying and off-putting.
The Apache Kafka Community here in the Twin Cities is very active; attendance is tracking high during the first week of announcing this event. If you are involved with real-time event processing please check out this meetup and I hope to see you there.
www.meetup.com/twincities-a...
www.meetup.com/twincities-a...
IN PERSON: Apache Kafka® Meetup, Tue, Apr 8, 2025, 5:00 PM | Meetup
Hello Streamers!
Please join us for an Apache Kafka® meetup hosted by Target on Tuesday evening, April 8th from 5:00pm!
📍**Venue:**
Target Plaza Commons
1001 Nicollet Ma
www.meetup.com
March 21, 2025 at 2:34 PM
The Apache Kafka Community here in the Twin Cities is very active; attendance is tracking high during the first week of announcing this event. If you are involved with real-time event processing please check out this meetup and I hope to see you there.
www.meetup.com/twincities-a...
www.meetup.com/twincities-a...
Reposted by Neil Buesing
Thank you to Neil Buesing (@nbuesing.bsky.social) for speaking at #osn2025!
March 10, 2025 at 3:27 PM
Thank you to Neil Buesing (@nbuesing.bsky.social) for speaking at #osn2025!
I’ve already listened to Lady Gaga’s new album on Spotify (yesterday) in full. Today I get an email telling me about the new album. I would be more impressed with real-time services if they could use real-time data to NOT send me something I already obviously am aware of.
March 9, 2025 at 5:46 PM
I’ve already listened to Lady Gaga’s new album on Spotify (yesterday) in full. Today I get an email telling me about the new album. I would be more impressed with real-time services if they could use real-time data to NOT send me something I already obviously am aware of.
@intellijidea.com's IDE has a great Apache Kafka plugin.
This is a @kafkastreams.bsky.social's session window changelog topic -- maybe I can figure out how to get support natively for Kafka Stream windowing keys.
This is a @kafkastreams.bsky.social's session window changelog topic -- maybe I can figure out how to get support natively for Kafka Stream windowing keys.
March 5, 2025 at 1:37 PM
@intellijidea.com's IDE has a great Apache Kafka plugin.
This is a @kafkastreams.bsky.social's session window changelog topic -- maybe I can figure out how to get support natively for Kafka Stream windowing keys.
This is a @kafkastreams.bsky.social's session window changelog topic -- maybe I can figure out how to get support natively for Kafka Stream windowing keys.
There is just 6 hours left to submit to @confluent.bsky.social Current London 2025, the Data Streaming (formerly Kafka Summit) conference.
Now, we have literally seen submissions with < 1 minute to spare -- don't be that person.
sessionize.com/current-lond...
Now, we have literally seen submissions with < 1 minute to spare -- don't be that person.
sessionize.com/current-lond...
Current London 2025: Call for Speakers
Discover the World of Data StreamingEvent OverviewAttention data streaming engineers! The call for proposals for Current London 2025: The Data Streami...
sessionize.com
February 17, 2025 at 6:26 PM
There is just 6 hours left to submit to @confluent.bsky.social Current London 2025, the Data Streaming (formerly Kafka Summit) conference.
Now, we have literally seen submissions with < 1 minute to spare -- don't be that person.
sessionize.com/current-lond...
Now, we have literally seen submissions with < 1 minute to spare -- don't be that person.
sessionize.com/current-lond...
I recently discovered chrome-cli (github.com/prasmussen/c...). By also leveraging `fzf` I can now quickly close tabs by name/url.
chrome-cli list tablinks | sort | fzf -m | awk -F '[][]' '{print $2}' | cut -d ':' -f 2 | xargs -I {} chrome-cli close -t {}
revolutionary!
chrome-cli list tablinks | sort | fzf -m | awk -F '[][]' '{print $2}' | cut -d ':' -f 2 | xargs -I {} chrome-cli close -t {}
revolutionary!
January 22, 2025 at 5:54 PM
I recently discovered chrome-cli (github.com/prasmussen/c...). By also leveraging `fzf` I can now quickly close tabs by name/url.
chrome-cli list tablinks | sort | fzf -m | awk -F '[][]' '{print $2}' | cut -d ':' -f 2 | xargs -I {} chrome-cli close -t {}
revolutionary!
chrome-cli list tablinks | sort | fzf -m | awk -F '[][]' '{print $2}' | cut -d ':' -f 2 | xargs -I {} chrome-cli close -t {}
revolutionary!
On the day I migrated a Kafka cluster to KRaft, my inbox on my work email is... 500 -- is that a sign 🤣. A sign I need to deal with junk email vs. leaving it in my inbox.
November 26, 2024 at 10:34 PM
On the day I migrated a Kafka cluster to KRaft, my inbox on my work email is... 500 -- is that a sign 🤣. A sign I need to deal with junk email vs. leaving it in my inbox.
Football offsides should be if any part of you is behind the defender you are not offsides.
Remains objective and more true to the spirit of the rule.
Watching my two favorite Premier league teams facing each other: ARS/NFO.
@nts.bsky.social - your team planning it 2 hours, watching?
Remains objective and more true to the spirit of the rule.
Watching my two favorite Premier league teams facing each other: ARS/NFO.
@nts.bsky.social - your team planning it 2 hours, watching?
November 23, 2024 at 3:21 PM
Football offsides should be if any part of you is behind the defender you are not offsides.
Remains objective and more true to the spirit of the rule.
Watching my two favorite Premier league teams facing each other: ARS/NFO.
@nts.bsky.social - your team planning it 2 hours, watching?
Remains objective and more true to the spirit of the rule.
Watching my two favorite Premier league teams facing each other: ARS/NFO.
@nts.bsky.social - your team planning it 2 hours, watching?
November 22, 2024 at 12:14 AM
My son and I play this every day and share results. I really enjoy the weekly challenges that come out on Monday.
#Travle
travle.earth
#Travle
travle.earth
travle
Travle: A daily game, get between countries in as few guesses as possible!
travle.earth
November 14, 2024 at 1:39 PM
My son and I play this every day and share results. I really enjoy the weekly challenges that come out on Monday.
#Travle
travle.earth
#Travle
travle.earth
I am a big fan of gradle and the gradle assembly plugin, but when running `gradle run` Control-C is not propagated to the application. When it comes to kafka-streams, this leads to an unclean shutdown.
I have my own `run.sh` and have a custom task that generates a `.classpath.sh` on assembly.
I have my own `run.sh` and have a custom task that generates a `.classpath.sh` on assembly.
introvert.com
run.sh
November 14, 2024 at 11:44 AM
I am a big fan of gradle and the gradle assembly plugin, but when running `gradle run` Control-C is not propagated to the application. When it comes to kafka-streams, this leads to an unclean shutdown.
I have my own `run.sh` and have a custom task that generates a `.classpath.sh` on assembly.
I have my own `run.sh` and have a custom task that generates a `.classpath.sh` on assembly.
when using kafka-console-consumer for analyzing messages on a topic use
--key-deserializer=org.apache.kafka.common.serialization.BytesDeserializer
--property print.key=true
You will easily see if you put SR content into your key (unexpectantly).
#ApacheKafka
--key-deserializer=org.apache.kafka.common.serialization.BytesDeserializer
--property print.key=true
You will easily see if you put SR content into your key (unexpectantly).
#ApacheKafka
November 13, 2024 at 1:00 PM
when using kafka-console-consumer for analyzing messages on a topic use
--key-deserializer=org.apache.kafka.common.serialization.BytesDeserializer
--property print.key=true
You will easily see if you put SR content into your key (unexpectantly).
#ApacheKafka
--key-deserializer=org.apache.kafka.common.serialization.BytesDeserializer
--property print.key=true
You will easily see if you put SR content into your key (unexpectantly).
#ApacheKafka
It’s nice being on a platform where I’m learning stuff again.
November 13, 2024 at 11:55 AM
It’s nice being on a platform where I’m learning stuff again.
Your puppy sleeping on you lap at 5am is very therapeutic.
November 12, 2024 at 11:44 AM
Your puppy sleeping on you lap at 5am is very therapeutic.
If you upgrade Docker Home (at least on your Mac), kill all gradle daemon processes. I could run `docker` just fine from my shell, but I guess not from an already running gradle daemon.
Caused by: IOException: Cannot run program "docker" (in directory "..."): error=2, No such file or directory.
Caused by: IOException: Cannot run program "docker" (in directory "..."): error=2, No such file or directory.
November 11, 2024 at 8:36 PM
If you upgrade Docker Home (at least on your Mac), kill all gradle daemon processes. I could run `docker` just fine from my shell, but I guess not from an already running gradle daemon.
Caused by: IOException: Cannot run program "docker" (in directory "..."): error=2, No such file or directory.
Caused by: IOException: Cannot run program "docker" (in directory "..."): error=2, No such file or directory.
With #ApacheKafka 4.0 coming in 2025, KIP-896 is still in the planned section of the release notes. Now is the time to find those old clients and upgrade them.
cwiki.apache.org/confluence/d...
cwiki.apache.org/confluence/d...
cwiki.apache.org/confluence/d...
cwiki.apache.org/confluence/d...
KIP-896: Remove old client protocol API versions in Kafka 4.0 - Apache Kafka - Apache Software Foundation
cwiki.apache.org
November 10, 2024 at 7:25 PM
With #ApacheKafka 4.0 coming in 2025, KIP-896 is still in the planned section of the release notes. Now is the time to find those old clients and upgrade them.
cwiki.apache.org/confluence/d...
cwiki.apache.org/confluence/d...
cwiki.apache.org/confluence/d...
cwiki.apache.org/confluence/d...
I am working on dashboards around KIP-714. Building dashboards around less-frequently polling of the metrics; I now appreciate the _rate metrics with the _total. In Grafana I would do rate(..._total{}[$__rate_interval], but if I want to poll less frequently, doesn't work out so well.
#ApacheKafka
#ApacheKafka
November 10, 2024 at 7:19 PM
I am working on dashboards around KIP-714. Building dashboards around less-frequently polling of the metrics; I now appreciate the _rate metrics with the _total. In Grafana I would do rate(..._total{}[$__rate_interval], but if I want to poll less frequently, doesn't work out so well.
#ApacheKafka
#ApacheKafka
On the left consumer lag as reported from the scraping metrics about the client from the client.
On the right is consumer lag leveraging KIP-714, scraping metrics about the client from an OTEL collector integrated with the broker.
On the right is consumer lag leveraging KIP-714, scraping metrics about the client from an OTEL collector integrated with the broker.
October 28, 2024 at 12:24 PM
On the left consumer lag as reported from the scraping metrics about the client from the client.
On the right is consumer lag leveraging KIP-714, scraping metrics about the client from an OTEL collector integrated with the broker.
On the right is consumer lag leveraging KIP-714, scraping metrics about the client from an OTEL collector integrated with the broker.