Member since 
    
	
		
		
		04-01-2021
	
	
	
	
	
	
	
	
	
	
	
	
	
	
			
      
                2
            
            
                Posts
            
        
                0
            
            
                Kudos Received
            
        
                0
            
            
                Solutions
            
        
			
    
	
		
		
		04-01-2021
	
		
		07:27 AM
	
	
	
	
	
	
	
	
	
	
	
	
	
	
		
	
				
		
			
					
				
		
	
		
					
							 Hello,  I'm using nifi 1.13.2 in 4 nodes cluster. My flow tries to consumes record from Kafka then map some data and send them to AMQ. I need to keep the order of retrieved records and send them in the same order. 
 I tried set execution on primary node only for every processor in group. I also set up max.pool.records (ConsumeKafka) and Concurrent tasks to 1. Next i set 1 sec run shedule and it doesn't work. Records are consumed with 10ms delay, not a 1 sec and the sequence is not conserved. 
 Thanks in advance. 
						
					
					... View more
				
			
			
			
			
			
			
			
			
			
		
		
			
				
						
							Labels:
						
						
		
			
	
					
			
		
	
	
	
	
				
		
	
	
- Labels:
 - 
						
							
		
			Apache Kafka
 - 
						
							
		
			Apache NiFi