Neil Buesing

@nbuesing.bsky.social

Kafka architect & developer, Java developer

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.

Bild

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.

Bild

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...

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

meetup.com

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.

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...

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

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.

Bild

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?

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.

introvert.com

run.sh

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

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.

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

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.

Bild

Working on my kafka-streams-dashboard project to showcase KIP-714 (consumer metrics) & improving sasl cluster, so I can showcase client metrics & their use of principal w/metrics. Current issue is getting librdkafka 2.6.0 client to send their metrics to the brokers 🤞. github.com/kineticedge/...

GitHub - kineticedge/kafka-streams-dashboards: showcases Grafana dashboards for Kafka Stream applications leveraging client JMX metrics.

showcases Grafana dashboards for Kafka Stream applications leveraging client JMX metrics. - kineticedge/kafka-streams-dashboards

github.com

When you refactor a KafkaStreams topology and imagine it will provide a great performance improvement, only to realize it doesn’t. Theory != Actual 🤔😔 Still cleaner to read, but is that enough to suggest the refactor?