Sample.aplf

 Sample;start;cr

 ⍝ Topic created with
 ⍝
 ⍝     kafka-topics.sh \
 ⍝       --bootstrap-server localhost:9092 \
 ⍝       --create --topic "animals" \
 ⍝       --partitions 3

 ⍝ Call to Init function
 Init 'path/to/dir/housing/kafka/shared/lib'

 consumer←⎕NEW Consumer

 consumer.configure'bootstrap.servers' 'localhost:9092' ⍝'grs3550.insight.local:9092'
 consumer.configure'client.id' 'martina'⍝'bhcgrs3550'
 consumer.configure'group.id' 'dyalog'

 l←consumer.topic_partition

 consumer.set_topic_partition l'animals'
 consumer.subscribe_topic_partition l
 ⎕DL 5


 bb←⎕NEW #.Record('animals' 'Blackbird' 'birds')
 so←⎕NEW #.Record('animals' 'Sole' 'fish')
 ef←⎕NEW #.Record('animals' 'Elefant' 'mamal')

 producer←⎕NEW Producer
 producer.configure'bootstrap.servers' 'localhost:9092'⍝'grs3550.insight.local:9092'
 producer.configure'client.id' 'martina'⍝'bhc'

 producer.produce_record bb
 producer.produce_record so
 producer.produce_record ef

 ⎕DL 1
 producer.delivery_report 13

 start←3⊃⎕AI
 :While 1
     cr←consumer.consume_record
     :If 1=⊃cr
     :AndIf 20000>(3⊃⎕AI)-start
         ⎕DL 0.2
         :Continue
     :ElseIf 0=⊃cr
         (2⊃cr).(Topic Payload Key Partition)
         start←0
     :Else
         cr
         :Leave
     :EndIf
 :EndWhile
 ⎕EX'producer'
 ⎕EX'consumer'