kafka-tutorials
kafka-tutorials copied to clipboard
confluentinc
Tutorials and Recipes for Apache Kafka
wrt https://kafka-tutorials.confluent.io/how-to-count-messages-on-a-kafka-topic/ksql.html > by default, ksqlDB emits table results every 2 seconds (based on default commit.interval.ms) > Maybe a little extra explanation would be helpful. While Without this, ksqlDB will...
From @rspurgeon: (sorry, formatting is off as this is copy/paste from [Slack](https://confluent.slack.com/archives/CHMFCJRCM/p1635260386008200)) Building a new tutorial I’m seeing this current instruction in our Confluent KTs: 3. Click on LEARN and...
For example: https://kafka-tutorials.confluent.io/creating-first-apache-kafka-producer-application/kafka.html In step 2 we instruction to launch CP w/ `docker-compose up -d` In step 9 we mention shutting down by `Now close the consumer with a CTRL+C...
Update Confluent flavored tutorials Production section w/ a more thorough config for Confluent Cloud
The current `Confluent` tutorials give a sparse configuration, like ``` bootstrap.servers= key.serializer=org.apache.kafka.common.serialization.StringSerializer value.serializer=org.apache.kafka.common.serialization.StringSerializer acks=all #Properties below this line are specific to code in this application input.topic.name= output.topic.name= ``` But this...
https://www.confluent.io/blog/introducing-confluent-parallel-message-processing-client/ https://github.com/confluentinc/parallel-consumer cc: @astubbs
Show advanced workflow with collection data types (arrays, maps, structs) and the lambda functions (reduce/transform/filter) Examples from @blueedgenick (thank you!) 1. A dating site : full 3-stage sequence to identify...
IMHO the two new pieces should be denoted somehow as different elements. At the moment they are too close to body text and so the user requires more cycles to...
For documentation, not sure if there's any needed fix or action > The problem is that users (and Semaphore tests) don’t checkout the full project (with properties file and jar),...
For the tutorial below https://kafka-tutorials.confluent.io/finding-distinct-events/ksql.html A table is created as below ``` CREATE TABLE DETECTED_CLICKS AS SELECT IP_ADDRESS AS KEY1, URL AS KEY2, TIMESTAMP AS KEY3, AS_VALUE(IP_ADDRESS) AS IP_ADDRESS, AS_VALUE(URL)...
For the tutorial below https://kafka-tutorials.confluent.io/finding-distinct-events/ksql.html If we don't make use of "TIMESTAMP", I see TOMBSTONE Messages. What is the reason for this? The CLICKS stream is modified to not include...