From a80b58b79eebf375562f34a79ae9573c0538a864 Mon Sep 17 00:00:00 2001 From: milessabin Date: Thu, 1 Aug 2024 10:57:46 +0000 Subject: [PATCH] deploy: 23b01492a8f35198d970a5523ee94e40ac49759e --- api/index.html | 4 ++-- docs/index.html | 20 ++++++++++---------- docs/kafka-client-metrics.html | 4 ++-- docs/kafka-consumers.html | 4 ++-- docs/kafka-producers.html | 4 ++-- docs/schema-registry.html | 4 ++-- index.html | 4 ++-- 7 files changed, 22 insertions(+), 22 deletions(-) diff --git a/api/index.html b/api/index.html index 9bbd57f5..a750e9d6 100644 --- a/api/index.html +++ b/api/index.html @@ -1,4 +1,4 @@ - - + + diff --git a/docs/index.html b/docs/index.html index 6ee55446..699ad9a8 100644 --- a/docs/index.html +++ b/docs/index.html @@ -56,7 +56,7 @@
- + @@ -76,7 +76,7 @@
- + @@ -190,7 +190,7 @@

ClientId("producer-example") ) // producer: Resource[IO, ProducerApi[IO, org.apache.avro.generic.GenericRecord, org.apache.avro.generic.GenericRecord]] = Allocate( -// resource = cats.effect.kernel.Resource$$$Lambda$10670/0x0000000102f61840@2b3dd776 +// resource = cats.effect.kernel.Resource$$$Lambda$11989/0x0000000103153040@5ec29e8d // )

And we'll define some customer records to be written:

import org.apache.kafka.clients.producer.ProducerRecord
@@ -221,16 +221,16 @@ 
Writing typed records with an Avro4s producer

         
Turning a generic producer into a typed producer is simple. We first ensure that com.sksamuel.avro4s.RecordFormat instances for our data are in scope:

         
implicit val CustomerRecordFormat = com.sksamuel.avro4s.RecordFormat[Customer]
-// CustomerRecordFormat: com.sksamuel.avro4s.RecordFormat[Customer] = com.sksamuel.avro4s.RecordFormat$$anon$1@118524c
+// CustomerRecordFormat: com.sksamuel.avro4s.RecordFormat[Customer] = com.sksamuel.avro4s.RecordFormat$$anon$1@cdd69b9
 implicit val CustomerIdRecordFormat = com.sksamuel.avro4s.RecordFormat[CustomerId]
-// CustomerIdRecordFormat: com.sksamuel.avro4s.RecordFormat[CustomerId] = com.sksamuel.avro4s.RecordFormat$$anon$1@6245a179

+// CustomerIdRecordFormat: com.sksamuel.avro4s.RecordFormat[CustomerId] = com.sksamuel.avro4s.RecordFormat$$anon$1@143c0102

And with those implicits in scope, we can create our producer:

val avro4sProducer = producer.map(_.toAvro4s[CustomerId, Customer])
 // avro4sProducer: Resource[IO, ProducerApi[[A]IO[A], CustomerId, Customer]] = Bind(
 //   source = Allocate(
-//     resource = cats.effect.kernel.Resource$$$Lambda$10670/0x0000000102f61840@2b3dd776
+//     resource = cats.effect.kernel.Resource$$$Lambda$11989/0x0000000103153040@5ec29e8d
 //   ),
-//   fs = cats.effect.kernel.Resource$$Lambda$10798/0x000000010306d840@4e757807
+//   fs = cats.effect.kernel.Resource$$Lambda$12117/0x0000000103291840@351f68ac
 // )

We can now write our typed customer records successfully!

import cats.effect.unsafe.implicits.global
@@ -259,11 +259,11 @@ 
// consumer: Resource[IO, ConsumerApi[IO, CustomerId, Customer]] = Bind(
 //   source = Bind(
 //     source = Allocate(
-//       resource = cats.effect.kernel.Resource$$$Lambda$10670/0x0000000102f61840@7d8b234c
+//       resource = cats.effect.kernel.Resource$$$Lambda$11989/0x0000000103153040@40752429
 //     ),
-//     fs = com.banno.kafka.consumer.ConsumerApi$Avro$$$Lambda$10801/0x000000010306f040@9c484df
+//     fs = com.banno.kafka.consumer.ConsumerApi$Avro$$$Lambda$12120/0x0000000103293040@3b5ecbb6
 //   ),
-//   fs = cats.effect.kernel.Resource$$Lambda$10798/0x000000010306d840@2a65534e
+//   fs = cats.effect.kernel.Resource$$Lambda$12117/0x0000000103291840@1f8dbabd
 // )

With our Kafka consumer in hand, we'll assign to our consumer our topic partition, with no offsets, so that it starts reading from the first record, and read a stream of records from our Kafka topic:

import org.apache.kafka.common.TopicPartition
diff --git a/docs/kafka-client-metrics.html b/docs/kafka-client-metrics.html
index b6cd2651..f78d0873 100644
--- a/docs/kafka-client-metrics.html
+++ b/docs/kafka-client-metrics.html
@@ -56,7 +56,7 @@
 
   

     
-    
+    
   
     
   
@@ -76,7 +76,7 @@
 
   

     
-    
+    
   
     
   
diff --git a/docs/kafka-consumers.html b/docs/kafka-consumers.html
index ebf5a017..89b2618e 100644
--- a/docs/kafka-consumers.html
+++ b/docs/kafka-consumers.html
@@ -56,7 +56,7 @@
 
   

     
-    
+    
   
     
   
@@ -76,7 +76,7 @@
 
   

     
-    
+    
   
     
   
diff --git a/docs/kafka-producers.html b/docs/kafka-producers.html
index 86c9b2fe..4cc0def8 100644
--- a/docs/kafka-producers.html
+++ b/docs/kafka-producers.html
@@ -56,7 +56,7 @@
 
   

     
-    
+    
   
     
   
@@ -76,7 +76,7 @@
 
   

     
-    
+    
   
     
   
diff --git a/docs/schema-registry.html b/docs/schema-registry.html
index 3a9e5e2c..6625293c 100644
--- a/docs/schema-registry.html
+++ b/docs/schema-registry.html
@@ -56,7 +56,7 @@
 
   

     
-    
+    
   
     
   
@@ -76,7 +76,7 @@
 
   

     
-    
+    
   
     
   
diff --git a/index.html b/index.html
index 3896c77b..f4f217f5 100644
--- a/index.html
+++ b/index.html
@@ -56,7 +56,7 @@
 
   

     
-    
+    
   
     
   
@@ -76,7 +76,7 @@
 
   

     
-    
+