java - How long the messages will be kept stored in topic/partition using kafka 0.9 -


i'm using kafkaconsumer api fetch data topic (one partition per topic), after records has been retrieved poll method , processed, if new instance of kafkaconsumer created , try fetch data same topic/partition i'm able retrieve same data in first time. there way remove records topic/partition after has been consumed ?


Comments

Post a Comment

Popular posts from this blog

authentication - Mongodb revoke acccess to connect test database -

i have ec2 instance mongodb 3.2.0 installed. have user admin access. can connect user , perform operation remotely. 1 can connect database test remote if knows ip mongo 11.11.11.11. although not able make operations, want restrict access user credentials can connect server. first need create users , grant roles users, example: use admin db.createuser( { user: "myuseradmin", pwd: "abc123", roles: [ { role: "useradminanydatabase", db: "admin" } ] } ) then need start server --auth parameter mongod --auth more information here
Read more

c - getting error: cannot take the address of an rvalue of type 'int' -

i tryed compile old code new compiler , got next error: error: cannot take address of rvalue of type 'int' here example 2 lines - 1 compiles , other gives error struct mstct { int myfield; int myfield2[5]; int myfield3[5]; }; typedef struct mstct db_data_px; int foo(int a, int b, int c){ //the next code compiles successfully. unsigned val1 = ((18 == c) ? ((unsigned) & (((db_data_px *) 0)->myfield)) : ((unsigned) & (((db_data_px *) 0)->myfield3[b]))); //successes //the next code failing unsigned val2 = (unsigned) & ((18 == c) ? (((db_data_px *) 0)->myfield) : (((db_data_px *) 0)->myfield3[b])); return 0; // failing } why first line compiles , second failing ? why need cast (unsigned) & in both of select expression , not enough cast after select expression valued ? in code ((18 == c) ? (((db_data_px *) 0)->myfield) : (((db_data_px *) 0)->myfield3[b])) is conditional expression not produce lva...
Read more

How to merge four videos on one screen with ffmpeg -

Image
this question has answer here: video grid vstack , hstack 1 answer i have video test.mp4, , need make appear 4 times @ once on screen. here found command makes 2 videos appear @ time ffmpeg -i input0.avi -vf "movie=input1.avi [in1]; [in]pad=640*2:352[in0]; [in0][in1] overlay=640:0 [out]" out.avi but doesn't work mp4 videos, , need 4 videos @ time. thank in advance four different inputs ffmpeg -i input0 -i input1 -i input2 -i input3 -filter_complex \ "[0:v][1:v]hstack[top]; \ [2:v][3:v]hstack[bottom]; \ [top][bottom]vstack,format=yuv420p[v]; \ [0:a][1:a][2:a][3:a]amerge=inputs=4[a]" \ -map "[v]" -map "[a]" -ac 2 output.mp4 two hstack instances make top , bottom, vstack combines those. amerge combines audio streams, -ac 2 downmixes them stereo. same input ffmpeg -i input \ -filter_complex ...
Read more