Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/LearningJournal/ApacheKafkaTutorials
/ functions
Functions
244 in github.com/LearningJournal/ApacheKafkaTutorials
⨍
Functions
244
◇
Types & classes
29
↓ 47 callers
Method
put
(int field$, java.lang.Object value$)
AvroConsumer-V2/ClickRecord.java:70
↓ 18 callers
Method
close
()
ProducerExamples/SensorPartitioner.java:34
↓ 17 callers
Method
get
(int field$)
AvroConsumer-V2/ClickRecord.java:55
↓ 8 callers
Method
partition
(String topic, Object key, byte[] keyBytes, Object value, byte[] valueBytes, Cluster cluster)
ProducerExamples/SensorPartitioner.java:16
↓ 6 callers
Method
put
(int field$, java.lang.Object value$)
AvroConsumer-V1/ClickRecord.java:62
↓ 4 callers
Method
getID
()
ProducerExamples/Supplier.java:13
↓ 4 callers
Method
getName
()
ProducerExamples/Supplier.java:17
↓ 4 callers
Method
getStartDate
()
ProducerExamples/Supplier.java:21
↓ 4 callers
Method
put
(int field$, java.lang.Object value$)
AvroProducer-V1/ClickRecord.java:62
↓ 4 callers
Method
put
(int field$, java.lang.Object value$)
AvroProducer-V2/ClickRecord.java:70
↓ 3 callers
Method
getOffsetFromDB
(TopicPartition p)
ConsumerExample/SensorConsumer.java:56
↓ 1 callers
Method
addOffset
(String topic, int partition, long offset)
ConsumerExample/RebalanceListner.java:13
↓ 1 callers
Method
get
(int field$)
AvroProducer-V1/ClickRecord.java:49
↓ 1 callers
Method
get
(int field$)
AvroProducer-V2/ClickRecord.java:55
↓ 1 callers
Method
getChannel
Gets the value of the 'channel' field. @return The value of the 'channel' field.
AvroConsumer-V2/ClickRecord.java:137
↓ 1 callers
Method
getChannel
Gets the value of the 'channel' field. @return The value of the 'channel' field.
AvroConsumer-V1/ClickRecord.java:127
↓ 1 callers
Method
getEntryUrl
Gets the value of the 'entry_url' field. @return The value of the 'entry_url' field.
AvroConsumer-V2/ClickRecord.java:153
↓ 1 callers
Method
getLanguage
Gets the value of the 'language' field. @return The value of the 'language' field.
AvroConsumer-V2/ClickRecord.java:185
↓ 1 callers
Method
getReferrer
Gets the value of the 'referrer' field. @return The value of the 'referrer' field.
AvroConsumer-V1/ClickRecord.java:143
↓ 1 callers
Method
getSessionId
Gets the value of the 'session_id' field. @return The value of the 'session_id' field.
AvroConsumer-V2/ClickRecord.java:89
↓ 1 callers
Method
getSessionId
Gets the value of the 'session_id' field. @return The value of the 'session_id' field.
AvroProducer-V1/ClickRecord.java:79
↓ 1 callers
Method
getSessionId
Gets the value of the 'session_id' field. @return The value of the 'session_id' field.
AvroConsumer-V1/ClickRecord.java:79
↓ 1 callers
Method
getSessionId
Gets the value of the 'session_id' field. @return The value of the 'session_id' field.
AvroProducer-V2/ClickRecord.java:89
↓ 1 callers
Method
saveAndCommit
(KafkaConsumer<String, String> c, ConsumerRecord<String, String> r)
ConsumerExample/SensorConsumer.java:75
↓ 1 callers
Method
setChannel
Sets the value of the 'channel' field. @param value the value to set.
AvroProducer-V1/ClickRecord.java:135
↓ 1 callers
Method
setChannel
Sets the value of the 'channel' field. @param value the value to set.
AvroProducer-V2/ClickRecord.java:145
↓ 1 callers
Method
setEntryUrl
Sets the value of the 'entry_url' field. @param value the value to set.
AvroProducer-V2/ClickRecord.java:161
↓ 1 callers
Method
setIp
Sets the value of the 'ip' field. @param value the value to set.
AvroProducer-V1/ClickRecord.java:167
↓ 1 callers
Method
setIp
Sets the value of the 'ip' field. @param value the value to set.
AvroProducer-V2/ClickRecord.java:177
↓ 1 callers
Method
setLanguage
Sets the value of the 'language' field. @param value the value to set.
AvroProducer-V2/ClickRecord.java:193
↓ 1 callers
Method
setOs
Sets the value of the 'os' field. @param value the value to set.
AvroProducer-V2/ClickRecord.java:209
↓ 1 callers
Method
setSessionId
Sets the value of the 'session_id' field. @param value the value to set.
AvroProducer-V1/ClickRecord.java:87
↓ 1 callers
Method
setSessionId
Sets the value of the 'session_id' field. @param value the value to set.
AvroProducer-V2/ClickRecord.java:97
Method
Builder
Creates a new Builder
AvroConsumer-V2/ClickRecord.java:255
Method
Builder
Creates a new Builder
AvroProducer-V1/ClickRecord.java:211
Method
Builder
Creates a new Builder
AvroConsumer-V1/ClickRecord.java:211
Method
Builder
Creates a new Builder
AvroProducer-V2/ClickRecord.java:255
Method
ClickRecord
Default constructor. Note that this does not initialize fields to their default values from the schema. If that is desired then one should use <code
AvroConsumer-V2/ClickRecord.java:29
Method
ClickRecord
Default constructor. Note that this does not initialize fields to their default values from the schema. If that is desired then one should use <code
AvroProducer-V1/ClickRecord.java:27
Method
ClickRecord
Default constructor. Note that this does not initialize fields to their default values from the schema. If that is desired then one should use <code
AvroConsumer-V1/ClickRecord.java:27
Method
ClickRecord
Default constructor. Note that this does not initialize fields to their default values from the schema. If that is desired then one should use <code
AvroProducer-V2/ClickRecord.java:29
Method
RebalanceListner
(KafkaConsumer con)
ConsumerExample/RebalanceListner.java:9
Method
Supplier
(int id, String name, Date dt)
ProducerExamples/Supplier.java:7
Method
build
()
AvroConsumer-V2/ClickRecord.java:651
Method
build
()
AvroProducer-V1/ClickRecord.java:513
Method
build
()
AvroConsumer-V1/ClickRecord.java:513
Method
build
()
AvroProducer-V2/ClickRecord.java:651
Method
clearBrowser
Clears the value of the 'browser' field. @return This builder.
AvroConsumer-V2/ClickRecord.java:411
Method
clearBrowser
Clears the value of the 'browser' field. @return This builder.
AvroProducer-V1/ClickRecord.java:351
Method
clearBrowser
Clears the value of the 'browser' field. @return This builder.
AvroConsumer-V1/ClickRecord.java:351
Method
clearBrowser
Clears the value of the 'browser' field. @return This builder.
AvroProducer-V2/ClickRecord.java:411
Method
clearCampaign
Clears the value of the 'campaign' field. @return This builder.
AvroConsumer-V2/ClickRecord.java:450
Method
clearCampaign
Clears the value of the 'campaign' field. @return This builder.
AvroProducer-V1/ClickRecord.java:390
Method
clearCampaign
Clears the value of the 'campaign' field. @return This builder.
AvroConsumer-V1/ClickRecord.java:390
Method
clearCampaign
Clears the value of the 'campaign' field. @return This builder.
AvroProducer-V2/ClickRecord.java:450
Method
clearChannel
Clears the value of the 'channel' field. @return This builder.
AvroConsumer-V2/ClickRecord.java:489
Method
clearChannel
Clears the value of the 'channel' field. @return This builder.
AvroProducer-V1/ClickRecord.java:429
Method
clearChannel
Clears the value of the 'channel' field. @return This builder.
AvroConsumer-V1/ClickRecord.java:429
Method
clearChannel
Clears the value of the 'channel' field. @return This builder.
AvroProducer-V2/ClickRecord.java:489
Method
clearEntryUrl
Clears the value of the 'entry_url' field. @return This builder.
AvroConsumer-V2/ClickRecord.java:528
Method
clearEntryUrl
Clears the value of the 'entry_url' field. @return This builder.
AvroProducer-V2/ClickRecord.java:528
Method
clearIp
Clears the value of the 'ip' field. @return This builder.
AvroConsumer-V2/ClickRecord.java:567
Method
clearIp
Clears the value of the 'ip' field. @return This builder.
AvroProducer-V1/ClickRecord.java:507
Method
clearIp
Clears the value of the 'ip' field. @return This builder.
AvroConsumer-V1/ClickRecord.java:507
Method
clearIp
Clears the value of the 'ip' field. @return This builder.
AvroProducer-V2/ClickRecord.java:567
Method
clearLanguage
Clears the value of the 'language' field. @return This builder.
AvroConsumer-V2/ClickRecord.java:606
Method
clearLanguage
Clears the value of the 'language' field. @return This builder.
AvroProducer-V2/ClickRecord.java:606
Method
clearOs
Clears the value of the 'os' field. @return This builder.
AvroConsumer-V2/ClickRecord.java:645
Method
clearOs
Clears the value of the 'os' field. @return This builder.
AvroProducer-V2/ClickRecord.java:645
Method
clearReferrer
Clears the value of the 'referrer' field. @return This builder.
AvroProducer-V1/ClickRecord.java:468
Method
clearReferrer
Clears the value of the 'referrer' field. @return This builder.
AvroConsumer-V1/ClickRecord.java:468
Method
clearSessionId
Clears the value of the 'session_id' field. @return This builder.
AvroConsumer-V2/ClickRecord.java:372
Method
clearSessionId
Clears the value of the 'session_id' field. @return This builder.
AvroProducer-V1/ClickRecord.java:312
Method
clearSessionId
Clears the value of the 'session_id' field. @return This builder.
AvroConsumer-V1/ClickRecord.java:312
Method
clearSessionId
Clears the value of the 'session_id' field. @return This builder.
AvroProducer-V2/ClickRecord.java:372
Method
close
()
ProducerExamples/SupplierDeserializer.java:50
Method
close
()
ProducerExamples/SupplierSerializer.java:46
Method
configure
(Map<String, ?> configs)
ProducerExamples/SensorPartitioner.java:11
Method
configure
(Map<String, ?> configs, boolean isKey)
ProducerExamples/SupplierDeserializer.java:13
Method
configure
(Map<String, ?> configs, boolean isKey)
ProducerExamples/SupplierSerializer.java:10
Method
deserialize
(String topic, byte[] data)
ProducerExamples/SupplierDeserializer.java:18
Method
get
(int field$)
AvroConsumer-V1/ClickRecord.java:49
Method
getBrowser
Gets the value of the 'browser' field. @return The value of the 'browser' field.
AvroConsumer-V2/ClickRecord.java:105
Method
getBrowser
Gets the value of the 'browser' field. @return The value.
AvroConsumer-V2/ClickRecord.java:382
Method
getBrowser
Gets the value of the 'browser' field. @return The value of the 'browser' field.
AvroProducer-V1/ClickRecord.java:95
Method
getBrowser
Gets the value of the 'browser' field. @return The value.
AvroProducer-V1/ClickRecord.java:322
Method
getBrowser
Gets the value of the 'browser' field. @return The value of the 'browser' field.
AvroConsumer-V1/ClickRecord.java:95
Method
getBrowser
Gets the value of the 'browser' field. @return The value.
AvroConsumer-V1/ClickRecord.java:322
Method
getBrowser
Gets the value of the 'browser' field. @return The value of the 'browser' field.
AvroProducer-V2/ClickRecord.java:105
Method
getBrowser
Gets the value of the 'browser' field. @return The value.
AvroProducer-V2/ClickRecord.java:382
Method
getCampaign
Gets the value of the 'campaign' field. @return The value of the 'campaign' field.
AvroConsumer-V2/ClickRecord.java:121
Method
getCampaign
Gets the value of the 'campaign' field. @return The value.
AvroConsumer-V2/ClickRecord.java:421
Method
getCampaign
Gets the value of the 'campaign' field. @return The value of the 'campaign' field.
AvroProducer-V1/ClickRecord.java:111
Method
getCampaign
Gets the value of the 'campaign' field. @return The value.
AvroProducer-V1/ClickRecord.java:361
Method
getCampaign
Gets the value of the 'campaign' field. @return The value of the 'campaign' field.
AvroConsumer-V1/ClickRecord.java:111
Method
getCampaign
Gets the value of the 'campaign' field. @return The value.
AvroConsumer-V1/ClickRecord.java:361
Method
getCampaign
Gets the value of the 'campaign' field. @return The value of the 'campaign' field.
AvroProducer-V2/ClickRecord.java:121
Method
getCampaign
Gets the value of the 'campaign' field. @return The value.
AvroProducer-V2/ClickRecord.java:421
Method
getChannel
Gets the value of the 'channel' field. @return The value.
AvroConsumer-V2/ClickRecord.java:460
Method
getChannel
Gets the value of the 'channel' field. @return The value of the 'channel' field.
AvroProducer-V1/ClickRecord.java:127
next →
1–100 of 244, ranked by callers