Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/amient/hello-kafka-streams
/ types & classes
Types & classes
10 in github.com/amient/hello-kafka-streams
⨍
Functions
35
◇
Types & classes
10
Class
ConnectEmbedded
This is only a temporary extension to Kafka Connect runtime until there is an Embedded API as per KIP-26
src/main/java/io/amient/kafka/connect/embedded/ConnectEmbedded.java:46
Class
IRCFeedConnector
A Generic Kafka Connector which takes a list of channels from an IRC server and creates 1 or more tasks depending on maxTasks configuration argument.
src/main/java/io/amient/kafka/connect/irc/IRCFeedConnector.java:35
Class
IRCFeedTask
src/main/java/io/amient/kafka/connect/irc/IRCFeedTask.java:34
Class
IRCMessage
Kafka Connect Domain object representing a generic IRC Message with its SCHEMA descriptor.
src/main/java/io/amient/kafka/connect/irc/IRCMessage.java:29
Class
IRCMessageListener
src/main/java/io/amient/kafka/connect/irc/IRCFeedTask.java:111
Class
JsonPOJOSerde
src/main/java/io/amient/examples/wikipedia/JsonPOJOSerde.java:28
Class
ShutdownHook
src/main/java/io/amient/kafka/connect/embedded/ConnectEmbedded.java:135
Enum
Type
src/main/java/io/amient/examples/wikipedia/WikipediaMessage.java:28
Class
WikipediaMessage
src/main/java/io/amient/examples/wikipedia/WikipediaMessage.java:26
Class
WikipediaStreamDemo
This is an equivalent of hello-samza project which transforms wikipedia irc channel events into wikipedia-raw and does some basic mapping and stateful
src/main/java/io/amient/examples/wikipedia/WikipediaStreamDemo.java:57