kafka java 例子 - 程式人生

1 、新建專案需要匯入以下包

2、建類生產者

import


java.util.Properties;

import


kafka.javaapi.producer.Producer;

import


kafka.producer.KeyedMessage;

import


kafka.producer.ProducerConfig;

public


class


TestProducer {

public


static


void


main(String[] args) {

Properties
 props =

new


Properties();

props.setProperty("metadata.broker.list","10.XX.XX.XX:9092"); props.setProperty("serializer.class","kafka.serializer.StringEncoder"); props.put("request.required.acks","1");

ProducerConfig
 config =

new


ProducerConfig(props);

Producer<String,
 String> producer =

new


Producer<String, String>(config);

KeyedMessage<String,
 String> data =

new


KeyedMessage<String, String>(

"mykafka","test-kafka"); try

int

i =

1; while

(i
 <

1000){ producer.send(data); } }catch


(Exception e) {

e.printStackTrace(); }

producer.close(); } }

3、消費者

import


java.util.HashMap;

import


              
           
              
              
            
            相關推薦
			   
            
            
            
 

    

    
    kafka java 例子
      
                

1 、新建專案 需要匯入以下包

2、建類  生產者

import

java.util.Properties; 

import

kafka.javaapi.producer.Producer; 
import

kafka.produ 

  
 

    

    
    kafka入門例子 for java
      
                
1，生產者

import java.util.Properties;

import kafka.javaapi.producer.Producer;
import kafka.producer.KeyedMessage;
import kafka.producer.Pr 

  
 

    

    
    Kafka筆記整理（二）：Kafka Java API使用
      大數據   Kafka   Java   [TOC]

Kafka筆記整理（二）：Kafka Java API使用
下面的測試代碼使用的都是下面的topic：
$ kafka-topics.sh --describe hadoop --zookeeper uplooking01:2181,uplooking0 

  
 

    

    
    Kafka java Client 錯誤 org.apache.kafka.clients.NetworkClient Error connecting to node 1 at slave2:909
       
 
  
  
  
  開發環境：win10+Eclipse  伺服器：centos+kafka0.10.2 
  
  
 錯誤： 
 [2017-09-09 13:34:40,648] [DEBUG] org.apache.kafka.clients.NetworkClient Initiating 

  
 

    

    
    簡單的kafka的例子
      
                kafka生產者

package cn.itcast.storm.kafka.simple;

import kafka.javaapi.producer.Producer;
import kafka.producer.KeyedMessage;
import kafka. 

  
 

    

    
    Kafka 學習筆記（3）——kafka java API
      
							
							
							1 新建maven 工程
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi= 

  
 

    

    
    人臉識別API-人臉檢測(java例子)
      
                檢測人臉圖片



HTTP傳送類

package engine.demo;

import java.io.ByteArrayOutputStream;
import java.io.InputStream;
import java.io.OutputStream;
im 

  
 

    

    
    人臉識別API-人臉屬性(java例子)
      
                人臉屬性



HTTP傳送類

package engine.demo;

import java.io.ByteArrayOutputStream;
import java.io.InputStream;
import java.io.OutputStream;
impo 

  
 

    

    
    正則表示式-Java例子
      
								
								            
						
                一、Java中使用Pattern類進行正則匹配

@org.junit.Test
	public void test1() {
		String regex = "^[\\s]*abc[\\s]";
	 

  
 

    

    
    amqp的Java例子程式碼解析---生產者
      
                /**
 * Licensed to the Apache Software Foundation (ASF) under one or more
 * contributor license agreements.  See the NOTICE file distribu 

  
 

    

    
    ZooKeeper官方Java例子解讀
      
                ZooKeeper官方提供了一個Java監聽的例子，本文是我對該例子的學習筆記。可以做為幫助理解此例子的資料：







需求理解

我們先回顧一下例子的需求，此客戶端有如下四個需求：

1、它接收如下引數：

ZooKeeper服務的地址
	被監控的znode的名稱
	 

  
 

    

    
    Kafka Java Consumer實現(一)
      
                Kafka提供了兩種Consumer API，分別是：High Level Consumer API 和 Lower Level Consumer API(Simple Consumer API)

High Level Consumer API：高度抽象的Kafka消費者A 

  
 

    

    
    Storm-Kafka模組常用介面分析及消費kafka資料例子
      
                
使用storm-kafka模組讀取kafka中的資料，按照以下兩步進行構建(我使用的版本是0.9.3)
1. 使用BrokerHosts介面來配置kafka broker host與partition的mapping資訊;
2. 使用KafkaConfig來配置一些與kaf 

  
 

    

    
    KafKa Java程式設計例項
       
 
 
 
  KafKa Java程式設計例項
 
 
  
 
 
  編寫一個能傳送訊息，接收訊息的例項
 
 
  （1）編寫係數配置：KafkaProperties.java
 
 
  
   
  
  
   
    
   
   
    
     
      
       p 

  
 

    

    
    Kafka Java
      
							
							
							 
 







Kafka在工程中的使用方法



在解決一個具體的業務需求時，原始資料從app、web、H5等多個來源傳輸到Kafka當中；此時，開發者則需要開發Kafka消費者，將其中的資料進行業務邏輯的開發。

而其中，消費Kafka的方式則通過Ja 

  
 

    

    
    kafka java 實現訊息佇列demo
      
                
kafka是吞吐量巨大的一個訊息系統，它是用scala寫的，和普通的訊息的生產消費還有所不同，寫了個demo程式供大家參考。kafka的安裝請參考官方文件。首先我們需要新建一個maven專案，然後在pom中引用kafka jar包，引用依賴如下：
   <depend 

  
 

    

    
    kafka java 主題及分割槽 副本操作程式碼
      
							
							
							package com.jingshan.topic;

import java.util.Properties;

import org.apache.kafka.common.security.JaasUtils;

import kafka.admin.A 

  
 

    

    
    初識Apache Kafka+JAVA程式例項
      
							
							
							　　本文是從英文的官網摘了翻譯的，用作自己的整理和記錄。水平有限，歡迎指正。版本是： kafka_2.10-0.10.0.0 
　　



一、基礎概念


主題：Kafka maintains feeds of messages in categories c 

  
 

    

    
    Kafka Java示例
      
                
   由於專案原因需要升級kafka，需要重新申請kafka服務，用新的Java API來編寫producer和consumer，順便接觸一下Kafka。準備工作就是安裝zookeeper和kafka，由於關於安裝方面的文章很多，在此就不細說了。
一、一些問題
1.1 ka 

  
 

    

    
    安裝kafka到window上,編寫kafka java客戶端連線kafka
      package com.kafka;

import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Properties;
import java.util.concurrent.Executo