This repository was archived by the owner on Jun 27, 2018. It is now read-only.
File tree 8 files changed +116
-0
lines changed
src/main/java/us/b3k/kafka/ws
8 files changed +116
-0
lines changed Original file line number Diff line number Diff line change @@ -38,3 +38,7 @@ Text messages are JSON objects with two attributes: topic and message.
38
38
## Configuration
39
39
40
40
See property files in conf/
41
+
42
+ ## License
43
+
44
+ kafka-websocket is copyright 2014 Benjamin Black, and distributed under the Apache License 2.0.
Original file line number Diff line number Diff line change
1
+ /*
2
+ Copyright 2014 Benjamin Black
3
+
4
+ Licensed under the Apache License, Version 2.0 (the "License");
5
+ you may not use this file except in compliance with the License.
6
+ You may obtain a copy of the License at
7
+
8
+ http://www.apache.org/licenses/LICENSE-2.0
9
+
10
+ Unless required by applicable law or agreed to in writing, software
11
+ distributed under the License is distributed on an "AS IS" BASIS,
12
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13
+ See the License for the specific language governing permissions and
14
+ limitations under the License.
15
+ */
16
+
1
17
package us .b3k .kafka .ws ;
2
18
3
19
import org .slf4j .Logger ;
Original file line number Diff line number Diff line change
1
+ /*
2
+ Copyright 2014 Benjamin Black
3
+
4
+ Licensed under the Apache License, Version 2.0 (the "License");
5
+ you may not use this file except in compliance with the License.
6
+ You may obtain a copy of the License at
7
+
8
+ http://www.apache.org/licenses/LICENSE-2.0
9
+
10
+ Unless required by applicable law or agreed to in writing, software
11
+ distributed under the License is distributed on an "AS IS" BASIS,
12
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13
+ See the License for the specific language governing permissions and
14
+ limitations under the License.
15
+ */
16
+
1
17
package us .b3k .kafka .ws ;
2
18
3
19
import java .io .FileInputStream ;
Original file line number Diff line number Diff line change
1
+ /*
2
+ Copyright 2014 Benjamin Black
3
+
4
+ Licensed under the Apache License, Version 2.0 (the "License");
5
+ you may not use this file except in compliance with the License.
6
+ You may obtain a copy of the License at
7
+
8
+ http://www.apache.org/licenses/LICENSE-2.0
9
+
10
+ Unless required by applicable law or agreed to in writing, software
11
+ distributed under the License is distributed on an "AS IS" BASIS,
12
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13
+ See the License for the specific language governing permissions and
14
+ limitations under the License.
15
+ */
16
+
1
17
package us .b3k .kafka .ws ;
2
18
3
19
import org .slf4j .Logger ;
Original file line number Diff line number Diff line change
1
+ /*
2
+ Copyright 2014 Benjamin Black
3
+
4
+ Licensed under the Apache License, Version 2.0 (the "License");
5
+ you may not use this file except in compliance with the License.
6
+ You may obtain a copy of the License at
7
+
8
+ http://www.apache.org/licenses/LICENSE-2.0
9
+
10
+ Unless required by applicable law or agreed to in writing, software
11
+ distributed under the License is distributed on an "AS IS" BASIS,
12
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13
+ See the License for the specific language governing permissions and
14
+ limitations under the License.
15
+ */
16
+
1
17
package us .b3k .kafka .ws .consumer ;
2
18
3
19
import kafka .consumer .ConsumerConfig ;
Original file line number Diff line number Diff line change
1
+ /*
2
+ Copyright 2014 Benjamin Black
3
+
4
+ Licensed under the Apache License, Version 2.0 (the "License");
5
+ you may not use this file except in compliance with the License.
6
+ You may obtain a copy of the License at
7
+
8
+ http://www.apache.org/licenses/LICENSE-2.0
9
+
10
+ Unless required by applicable law or agreed to in writing, software
11
+ distributed under the License is distributed on an "AS IS" BASIS,
12
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13
+ See the License for the specific language governing permissions and
14
+ limitations under the License.
15
+ */
16
+
1
17
package us .b3k .kafka .ws .messages ;
2
18
3
19
import org .slf4j .Logger ;
Original file line number Diff line number Diff line change
1
+ /*
2
+ Copyright 2014 Benjamin Black
3
+
4
+ Licensed under the Apache License, Version 2.0 (the "License");
5
+ you may not use this file except in compliance with the License.
6
+ You may obtain a copy of the License at
7
+
8
+ http://www.apache.org/licenses/LICENSE-2.0
9
+
10
+ Unless required by applicable law or agreed to in writing, software
11
+ distributed under the License is distributed on an "AS IS" BASIS,
12
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13
+ See the License for the specific language governing permissions and
14
+ limitations under the License.
15
+ */
16
+
1
17
package us .b3k .kafka .ws .messages ;
2
18
3
19
import com .google .gson .JsonObject ;
Original file line number Diff line number Diff line change
1
+ /*
2
+ Copyright 2014 Benjamin Black
3
+
4
+ Licensed under the Apache License, Version 2.0 (the "License");
5
+ you may not use this file except in compliance with the License.
6
+ You may obtain a copy of the License at
7
+
8
+ http://www.apache.org/licenses/LICENSE-2.0
9
+
10
+ Unless required by applicable law or agreed to in writing, software
11
+ distributed under the License is distributed on an "AS IS" BASIS,
12
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13
+ See the License for the specific language governing permissions and
14
+ limitations under the License.
15
+ */
16
+
1
17
package us .b3k .kafka .ws .producer ;
2
18
3
19
import kafka .javaapi .producer .Producer ;
You can’t perform that action at this time.
0 commit comments